首页 > 代码库 > MongoDB API - 简单的示例小程序
MongoDB API - 简单的示例小程序
阅读群体:对MOngoDB 尚且不够熟悉的初学者。
Plus: 由于本ID是第一次使用MongoDB,如出现理解的偏差,还请指出。
1 些概念:
一个MongoDB服务可以建立多个数据库,每一个数据库可以有多张表,通常而言,我们的数据库的表的名字叫
Collection,每一个Collection可以存放多个Document,每一个文档都以BSON(binary)的形式存放在硬盘之中,
因此可以存放比较复杂的形式存放在硬盘之中,因此可以存放比较复杂的对象,它是以文档的形式进行存储的。你可以给
任何的一个文档或者一批文档新增或则删除字段,而不会对其他的文档造成影响。这就是Schema-free, 和一般的Key -
value 数据库如下,这也是文档型数据库的主要优点,
跟一般的key-value数据库不一样的是,它的value中存储了结构信息,所以你又可以像关系型数据库那样对某些域进行读写、统计等操作。Mongo最大的特点是他支持的查询语言非常强大,其语法有点类似于面向对象的查询语言,几乎可以实现类似关系数据库单表查询的绝大部分功能,而且还支持对数据建立索引。Mongo还可以解决海量数据的查询效率,根据官方文档,当数据量达到50GB以上数据时,Mongo数据库访问速度是MySQL10 倍以上。
BSON 是binay json的缩写,BSON 有以下的三个特点:
1 轻量
2 夸平台
3 高效
命名空间: MongoDB 村粗BSON对象到COllections,这一系列的数据库名,和Colelctions被
成为一个命名空间。
一个小程序:
package test; import java.net.UnknownHostException; import java.util.ArrayList; import java.util.List; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import com.esotericsoftware.minlog.Log; import com.mixbox.mongodb.impl.MongoDBUtil; import com.mongodb.BasicDBObject; import com.mongodb.DB; import com.mongodb.DBCollection; import com.mongodb.Mongo; import com.mongodb.ServerAddress; public class testIpChecker { public static final Logger LOG = LoggerFactory.getLogger(MongoDBUtil.class); // mongodb地址 static ServerAddress address = null; // 集群地址集 static List<ServerAddress> list = new ArrayList<ServerAddress>(); // mongo对象 static Mongo m = null; // 数据库对象 static DB db = null; static { try { address = new ServerAddress("192.168.50.25", 30000); } catch (UnknownHostException e) { // TODO Auto-generated catch block e.printStackTrace(); } list.add(address); m = new Mongo(list); db = m.getDB("shoptest"); } public static void main(String[] args) throws Exception { MongoDBUtil mongoutil = new MongoDBUtil(); int needInc = mongoutil.checkHasIp("192.168.50.165"); // for (int i = 0; i < 100; i++) { // insertIntoMongo("192.168.50.165"); // // } isNeed(needInc); } public static void p(Object o) { System.err.println(o.toString()); } public static void isNeed(int needInc) { if (needInc == 1) { p("需要增加,库里面没有"); } else { p("不需要,库里有了"); } } public static void insertIntoMongo(String dimensionip) { DBCollection collection = db.getCollection("dimensionipbase"); // 获取表的句柄 // 封装查询条件 BasicDBObject basicDBObject = null; BasicDBObject newdbobject = new BasicDBObject(); newdbobject.put("dimensionip", dimensionip); collection.insert(newdbobject); } }
BasicDBobject 事实也对应着 Document对象。 利用BasicDBObject去管理。
MongoDB API - 简单的示例小程序