MongoDB表結構設計程式碼實現以及連線實現
1、以備檢視
表結構設計程式碼:
package cn.uestc.warningTest.warningTest; import org.bson.Document; public class TableDesign { private String time;//時間 private String phoneNum;//手機號 private String type;//型別 private String local;// 位置 private String out;//漫出 private String in;//漫入 private String context;//內容 public TableDesign(String phoneNum,String type,String context){ super(); this.phoneNum = phoneNum; this.type = type; this.context = context; } public Document getDoc(){ return new Document("手機號",phoneNum). append("預警型別",type). append("詳細內容", context); } public String getTime() { return time; } public void setTime(String time) { this.time = time; } public String getPhoneNum() { return phoneNum; } public void setPhoneNum(String phoneNum) { this.phoneNum = phoneNum; } public String getType() { return type; } public void setType(String type) { this.type = type; } public String getLocal() { return local; } public void setLocal(String local) { this.local = local; } public String getOut() { return out; } public void setOut(String out) { this.out = out; } public String getIn() { return in; } public void setIn(String in) { this.in = in; } public String getContext() { return context; } public void setContext(String context) { this.context = context; } }
2、MongoDB連線:
package cn.uestc.warningTest.warningTest; import java.util.ArrayList; import java.util.List; import org.bson.Document; import com.mongodb.BasicDBObject; import com.mongodb.MongoClient; import com.mongodb.client.FindIterable; import com.mongodb.client.MongoCollection; import com.mongodb.client.MongoCursor; import com.mongodb.client.MongoDatabase; import com.mongodb.connection.Connection; public class mongodbConnection { //mongodb資料庫連線 String url ; String dbase; String collect; Connection connection; String number; String IMSI; MongoCollection<Document> col; public mongodbConnection(String url,String dbase){ this.url= url; this.dbase = dbase; } public MongoCollection<Document> getConnection(String collect){ MongoClient client = new MongoClient(url,27019); MongoDatabase db = client.getDatabase(dbase); col =db.getCollection(collect) ; System.out.println("成功"); return col; } public MongoCursor<Document> query(String number, String simi,MongoCollection<Document> col){ BasicDBObject query = new BasicDBObject(); query.put("手機號", number); BasicDBObject query1 = new BasicDBObject(); query1.put("SIMI號", simi); List<BasicDBObject> orQueryList = new ArrayList<BasicDBObject>(); orQueryList.add(query); orQueryList.add(query1); BasicDBObject orQuery = new BasicDBObject("$or", orQueryList); FindIterable<Document> findIterable = col.find(orQuery); MongoCursor<Document> mongoCursor = findIterable.iterator(); return mongoCursor; } /*public static void main(String args[]){ mongodbConnection a = new mongodbConnection("192.168.0.75","warning","warn"); a.getConnection(); }*/ }
3、優化上面2的連線,用連線池實現:(單例模式)
package cn.uestc.warningTest.warningTest; import java.rmi.UnknownHostException; import java.util.ArrayList; import java.util.List; import org.bson.Document; import com.mongodb.BasicDBObject; import com.mongodb.MongoClient; import com.mongodb.MongoClientOptions; import com.mongodb.ServerAddress; import com.mongodb.client.FindIterable; import com.mongodb.client.MongoCollection; import com.mongodb.client.MongoCursor; import com.mongodb.client.MongoDatabase; public class ConnectionPool { private static MongoClient mongoClient = null; private static final ConnectionPool pool = new ConnectionPool(); private ConnectionPool(){ if(mongoClient == null){ MongoClientOptions.Builder buide = new MongoClientOptions.Builder(); buide.connectionsPerHost(100);// 與目標資料庫可以建立的最大連結數 buide.connectTimeout(1000 * 60 * 20);// 與資料庫建立連結的超時時間 buide.maxWaitTime(100 * 60 * 5);// 一個執行緒成功獲取到一個可用資料庫之前的最大等待時間 buide.threadsAllowedToBlockForConnectionMultiplier(100); buide.maxConnectionIdleTime(0); buide.maxConnectionLifeTime(0); buide.socketTimeout(0); MongoClientOptions myOptions = buide.build(); try{ mongoClient = new MongoClient(new ServerAddress("192.168.0.75",27019),myOptions); }catch(Exception e){ e.printStackTrace(); } } } public static ConnectionPool getConnectionPool(){ return pool; } public MongoDatabase getDB(String dbName){ return mongoClient.getDatabase(dbName); } public static MongoCollection<Document> getCollection(String dbName,String collectionName){ MongoDatabase db = mongoClient.getDatabase(dbName); return db.getCollection(collectionName); } public static MongoCursor<Document> query(String number, String simi,String dbName,String collectName){ MongoDatabase db = mongoClient.getDatabase(dbName); MongoCollection<Document> col =db.getCollection(collectName) ; BasicDBObject query = new BasicDBObject(); query.put("手機號", number); BasicDBObject query1 = new BasicDBObject(); query1.put("SIMI號", simi); List<BasicDBObject> orQueryList = new ArrayList<BasicDBObject>(); orQueryList.add(query); orQueryList.add(query1); BasicDBObject orQuery = new BasicDBObject("$or", orQueryList); FindIterable<Document> findIterable = col.find(orQuery); MongoCursor<Document> mongoCursor = findIterable.iterator(); return mongoCursor; } }
相關推薦
MongoDB表結構設計程式碼實現以及連線實現
1、以備檢視表結構設計程式碼:package cn.uestc.warningTest.warningTest; import org.bson.Document; public class TableDesign { private String time;//時間
表結構設計器(EZDML)1.98版公布
導出 asp 每一個 fcm blog iss pl/sql 字符串 分享 表結構設計器(EZDML)是一個免費的數據庫建表的小軟件,可高速的進行數據庫表結構設計。建立數據模型,能迅速生成代碼模板、簡單界面和字典文檔,支持腳本編程。
通過Excel生成PowerDesigner表結構設計
doc tables log ksh word 文件 aps 結構 image 說明:近期做部分表結構設計,在word裏設計調整好了,需要整理到PowerDesigner中,但是手工錄入太麻煩。 找了個工具(地址:http://www.cnblogs.com/hwaggLe
數據庫表結構設計方法及原則
管理 鍵值 lar 存儲引擎 ota mvcc 外鍵關聯 列排序 搜索 http://www.cnblogs.com/RunForLove/p/5693986.html 數據庫設計的三大範式:為了建立冗余較小、結構合理的數據庫,設計數據庫時必須遵循一定的規則。在關系型數據庫
JavaWeb | 之 | 角色管理的表結構設計和原理
添加 原理 com 數據庫表結構 效果 image 簡單 javaweb span 1, 根據實際工作的實際需要,不同的角色會有不同的權限,因此出現 角色管理,表結構總結如下: 首先:數據庫表結構: a.角色表: b.權限表: c.角
堡壘機表結構設計
profile .com fun string ssh 設計 ble urn int 一、堡壘機表結構 二、創建表 # -*- coding: UTF-8 -*- from sqlalchemy.ext.declarative import declarat
項目總結---表結構設計
庫存 訂單號 ont sql ice col 流水號 ren 順序 DROP TABLE IF EXISTS `mmall_user`; CREATE TABLE `mmall_user` ( `id` int(11) NOT NULL AUTO_INCREMENT
ofbiz數據庫表結構設計(3)- 訂單ORDER
商品 用戶 div 方法 狀態 ofb anti rem 填充 對於訂單來說,主要的表就是ORDER_HEADER和ORDER_ITEM。ORDER_HEADER就是所謂的訂單頭,一條記錄代表一條訂單。ORDER_PAYMENT_PREFERENCE
PHP 站內消息的表結構設計
位置 數據 全文檢索 mar 性能問題 設計 如果 處理 default 1)添加全站通知:信息存入到 tb_message 2)用戶點開信息或者設置信息為已閱讀:插入記錄到 tb_message_readlog 如何設計存儲的表?求最佳方案 CREATE TABLE `
博客系統需求分析和表結構設計
con ont __str__ fields key rim spl etime foreign 一、項目流程 1、搞清楚需求(產品經理) (1)基於用戶認證組件和Ajax實現登錄驗證(圖片驗證碼) (2)基於forms組件和Ajax實現註冊功能 (3)
主機管理+堡壘機系統開發:表結構設計
bsp http __str__ ipaddress color user del splay group 一、創建django項目和app web 二、主機表 1、主機表代碼: """存儲所有主機""" hostname = models.CharFi
系統資料字典表結構設計
CREATE TABLE `g_sys_dict` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'id', `pid` int(11) DEFAULT '0' COMMENT ' 父ID ', `data_type` varchar(50)
資料庫表結構設計原則
先談談我這些年趟過的資料庫的坑: 同義多詞。例如:在訂單表中申請單號用appseetserialno,而在支付日誌表中用appno。 同詞多義。例如:渠道這個欄位,可以用channel表示,在委託表中表示請求的來源渠道,eg:安卓、IOS、官網;在支付日誌表中表示支付的
使用者畫像—計算使用者偏好標籤及資料指標與表結構設計
一、使用者畫像—計算使用者偏好標籤 下面介紹如何計算使用者的偏好標籤。 在上一篇寫使用者畫像的文章 “使用者畫像—打使用者行為標籤”中,主要講了如何對使用者的每一次操作行為、業務行為進行記錄打上相應的標籤。在這篇部落格中,主要講如何對這些明細標籤進行計算以及偏好的產品、內容的類目。 關於
三級聯動--表結構設計
三級聯動作為一個非常鍛鍊新手的問題,經常被用來驗證同學們的學習效果,那麼今天我們就來講一講三級聯動的表結構設計 #刪除庫(如果資料庫db1存在) DROP DATABASE IF EXISTS db1; #建立utf8格式的資料庫db1(如果資料庫db1不存在) CREATE DATABASE
hbase表結構設計研究
因為一直在做hbase的應用層面的開發,所以體會的比較深的一點是hbase的表結構設計會對系統的效能以及開銷上造成很大的區別,本篇文章先按照hbase表中的rowkey、columnfamily、column、timestamp幾個方面進行
資料庫表結構設計
資料庫:ads 資料庫模型類基類:BaseModel class BaseModel(models.Model): """模型類基類""" create_time = models.DateTimeField(auto_now_add=True, verb
Django之CRM專案-表結構設計
1.展示客戶 模板的查詢順序: 先找全域性的templates——》 按照app的註冊順序找templates中的檔案 使用admin新增資料: 建立超級使用者 python manage.py createsuperuser 在admin中註冊model
mongodb使用總結01-基礎概念以及連線方法_md
step 1 基礎概念 在mongodb中基本的概念是 資料欄位/域(field)、 文件(document)、 集合(collection)、 資料庫(datebase), 把這些概念和關係型資料庫中的概念相互對比就會比較容易理解:
Redis的安裝與配置及表結構設計
一、Redis的安裝與配置 https://www.cnblogs.com/M-LittleBird/p/5902850.html 二、Redis伺服器和客戶端啟動 cd c:\redis redis-server redis.windows.conf redis-cli -h