分类数据库下的文章

mongodb基本操作

作者: admin
时间: 2017-03-20
分类: 数据库,mongodb
评论

mongod -f /home/data/mongodb/mongodb.cnf 启动

mongo --port=27018 本地登录

db.auth("zrp","****"); 认证

db.zrpdb.insert({name:"111"}); 插入数据

mongodb授权登录

作者: admin
时间: 2017-03-20
分类: 数据库,mongodb
评论

mongodb版本为3.2（目前最新），演示的是linux下的mongodb授权认证

第一次登录不启动授权（mongo默认不启动）

./mongod --dbpath=/home/db/data --logpath=/home/db/logs/mongodb.log

接着使用 ./mongo 命令连接数据库

 ./mongo

切换到admin数据库 use admin

使用创建用户命令：

use admin
db.createUser(
  {
    user: "coderhuang",
    pwd: "123456",
    roles: [ { role: "root", db: "admin" } ]
  }
)

则对admin数据库添加了名为coderhuang的用户（注：mongo为每一个数据库都提供了一套用户权限）

接着关闭数据库(注：当启动了授权认证，只有root角色有权限可以关闭数据库)

db.shutdownServer();

第二次登录启用授权认证：

./mongod --auth --dbpath=/home/db/data --logpath=/home/db/logs/mongodb.log

接着切换到admin数据库，使用查看用户命令

use admin
show users

将提示未授权

这时需要做授权认证

db.auth("coderhuang","123456");

再调用刚才的命令则可以查看到用户信息

接着我们需要为我们的数据库添加相关用户，这里使用db_report为示例

use db_report
db.createUser(
 {
   user: "client",
   pwd: "111111",
   roles: [
      { role: "readWrite", db: "db_report" }
   ]
 }
)

这里为db_report数据库添加了具有读写权限的角色

到此,mongo授权完成

http://www.cnblogs.com/coderhuang/p/5180259.html

JDBC操作MYSQL数据库

作者: admin
时间: 2017-03-07
分类: 数据库,Mysql,JAVA,JDBC
评论

JDBC操作数据库的基本步骤：

1）加载（注册）数据库驱动。

2）建立（获取）数据库连接。

3）创建（获取）数据库操作对象。

4）定义操作的SQL语句。

5）执行数据库操作。

6）获取并操作结果集。

7）关闭对象，回收数据库资源（关闭结果集-->关闭数据库操作对象-->关闭连接）。

以下是代码：

- 阅读剩余部分 -

MongoDB 原子操作

作者: admin
时间: 2017-02-23
分类: 数据库,JAVA,mongodb
评论

mongodb不支持事务，所以，在你的项目中应用时，要注意这点。无论什么设计，都不要要求mongodb保证数据的完整性。

但是mongodb提供了许多原子操作，比如文档的保存，修改，删除等，都是原子操作。

所谓原子操作就是要么这个文档保存到Mongodb，要么没有保存到Mongodb，不会出现查询到的文档没有保存完整的情况。

原子操作数据模型

考虑下面的例子，图书馆的书籍及结账信息。

实例说明了在一个相同的文档中如何确保嵌入字段关联原子操作（update：更新）的字段是同步的。

book= {_id: 123456789,title: "MongoDB: The Definitive Guide",author: [ "Kristina Chodorow", "Mike Dirolf" ],published_date: ISODate("2010-09-24"),pages: 216,language: "English",publisher_id: "oreilly",available: 3,checkout: [ { by: "joe",date: ISODate("2012-10-15") } ]
        }

你可以使用 db.collection.findAndModify() 方法来判断书籍是否可结算并更新新的结算信息。

在同一个文档中嵌入的 available 和 checkout 字段来确保这些字段是同步更新的:

db.books.findAndModify( {query: {_id: 123456789,available: {$gt: 0 }
          },update: {$inc: {available: -1 },$push: {checkout: { by: "abc",date: new Date() } }
           }
} )

原子操作常用命令

$set

用来指定一个键并更新键值，若键不存在并创建。

{$set: {field:value} }

$unset

用来删除一个键。

{$unset: {field: 1} }

$inc

$inc可以对文档的某个值为数字型（只能为满足要求的数字）的键进行增减的操作。

{$inc: {field:value} }

$push

用法：

{$push: {field:value} }

把value追加到field里面去，field一定要是数组类型才行，如果field不存在，会新增一个数组类型加进去。

$pushAll

同$push,只是一次可以追加多个值到一个数组字段内。

{$pushAll: {field:value_array} }

$pull

从数组field内删除一个等于value值。

{$pull: {field:_value} }

$addToSet

增加一个值到数组内，而且只有当这个值不在数组内才增加。

$pop

删除数组的第一个或最后一个元素

{$pop: {field: 1 } }

$rename

修改字段名称

{$rename: {old_field_name:new_field_name} }

$bit

位操作，integer类型

{$bit: {field: {and : 5}}}

偏移操作符

>t.find() { "_id" : ObjectId("4b97e62bf1d8c7152c9ccb74"), "title" : "ABC", "comments" : [ { "by" : "joe", "votes" : 3 }, { "by" : "jane", "votes" : 7 } ] }
 
>t.update( {'comments.by':'joe'}, {$inc:{'comments.$.votes':1}}, false, true )
 
>t.find() { "_id" : ObjectId("4b97e62bf1d8c7152c9ccb74"), "title" : "ABC", "comments" : [ { "by" : "joe", "votes" : 4 }, { "by" : "jane", "votes" : 7 } ] }

MongoDB Java

作者: admin
时间: 2017-02-23
分类: 数据库,JAVA,mongodb
评论

环境配置

在 Java 程序中如果要使用 MongoDB，你需要确保已经安装了 Java 环境及 MongoDB JDBC 驱动。

本章节实例时候 Mongo 3.x 以上版本。

你可以参考本站的Java教程来安装Java程序。现在让我们来检测你是否安装了 MongoDB JDBC 驱动。

首先你必须下载mongo jar包，下载地址：http://mongodb.github.io/mongo-java-driver/, 请确保下载最新版本。
你需要将 mongo-java-driver-3.2.2.jar （找到合适的版本）包含在你的 classpath 中。。
国内 mongodb-driver jar 下载地址：http://central.maven.org/maven2/org/mongodb/mongo-java-driver/

连接数据库

连接数据库，你需要指定数据库名称，如果指定的数据库不存在，mongo会自动创建数据库。

连接数据库的Java代码如下：

importcom.mongodb.MongoClient;
importcom.mongodb.client.MongoDatabase;

public class MongoDBJDBC{
   public static voidmain( Stringargs[] ){
      try{   
       // 连接到 mongodb 服务
         MongoClientmongoClient= new MongoClient( "localhost" , 27017 );
       
         // 连接到数据库
         MongoDatabasemongoDatabase=mongoClient.getDatabase("mycol");  
       System.out.println("Connect to database successfully");
        
      }catch(Exceptione){
        System.err.println(e.getClass().getName() + ": " +e.getMessage() );
     }
   }
}

现在，让我们来编译运行程序并连接到数据库 mycol。

你可以根据你的实际环境改变 MongoDB JDBC 驱动的路径。

本实例将 MongoDB JDBC 启动包 mongo-java-driver-3.2.2.jar 放在本地目录下:

$ javac-cp.:mongo-java-driver-3.2.2.jar MongoDBJDBC.java

$ java-cp.:mongo-java-driver-3.2.2.jar MongoDBJDBC
Connectto database successfullyAuthentication: true

本实例中 Mongo 数据库无需用户名密码验证。如果你的 Mongo 需要验证用户名及密码，可以使用以下代码：

importjava.util.ArrayList;  
importjava.util.List;  
importcom.mongodb.MongoClient;  
importcom.mongodb.MongoCredential;  
importcom.mongodb.ServerAddress;  
importcom.mongodb.client.MongoDatabase;  
  
public class MongoDBJDBC {  
    public static voidmain(String[]args){  
        try {  
            //连接到MongoDB服务 如果是远程连接可以替换“localhost”为服务器所在IP地址
            //ServerAddress()两个参数分别为 服务器地址 和 端口
            ServerAddressserverAddress= new ServerAddress("localhost",27017);  
            List<ServerAddress>addrs= new ArrayList<ServerAddress>();addrs.add(serverAddress);  
              
            //MongoCredential.createScramSha1Credential()三个参数分别为 用户名 数据库名称 密码
            MongoCredentialcredential= MongoCredential.createScramSha1Credential("username", "databaseName", "password".toCharArray());  
            List<MongoCredential>credentials= new ArrayList<MongoCredential>();credentials.add(credential);  
              
            //通过连接认证获取MongoDB连接
            MongoClientmongoClient= new MongoClient(addrs,credentials);  
              
            //连接到数据库
            MongoDatabasemongoDatabase=mongoClient.getDatabase("databaseName");  
            System.out.println("Connect to database successfully");  
        } catch (Exceptione) {  
            System.err.println(e.getClass().getName() + ": " +e.getMessage() );  
        }  
    }  
}

创建集合

我们可以使用 com.mongodb.client.MongoDatabase 类中的createCollection()来创建集合

代码片段如下：

importcom.mongodb.MongoClient;
importcom.mongodb.client.MongoDatabase;

public class MongoDBJDBC{
   public static voidmain( Stringargs[] ){
      try{   
      // 连接到 mongodb 服务
      MongoClientmongoClient= new MongoClient( "localhost" , 27017 );
         
       
      // 连接到数据库
      MongoDatabasemongoDatabase=mongoClient.getDatabase("mycol");  
      System.out.println("Connect to database successfully");mongoDatabase.createCollection("test");
      System.out.println("集合创建成功");
        
      }catch(Exceptione){
        System.err.println(e.getClass().getName() + ": " +e.getMessage() );
     }
   }
}

编译运行以上程序，输出结果如下:

Connectto database successfully集合创建成功

获取集合

我们可以使用com.mongodb.client.MongoDatabase类的 getCollection() 方法来获取一个集合

代码片段如下：

importorg.bson.Document;
importcom.mongodb.MongoClient;
importcom.mongodb.client.MongoCollection;
importcom.mongodb.client.MongoDatabase;

public class MongoDBJDBC{
   public static voidmain( Stringargs[] ){
      try{   
       // 连接到 mongodb 服务
         MongoClientmongoClient= new MongoClient( "localhost" , 27017 );
       
         // 连接到数据库
         MongoDatabasemongoDatabase=mongoClient.getDatabase("mycol");  
       System.out.println("Connect to database successfully");
      
       MongoCollection<Document>collection=mongoDatabase.getCollection("test");
       System.out.println("集合 test 选择成功");
      }catch(Exceptione){
        System.err.println(e.getClass().getName() + ": " +e.getMessage() );
     }
   }
}

编译运行以上程序，输出结果如下:

Connectto database successfully集合test选择成功

插入文档

我们可以使用com.mongodb.client.MongoCollection类的 insertMany() 方法来插入一个文档

代码片段如下：

importjava.util.ArrayList;
importjava.util.List;
importorg.bson.Document;

importcom.mongodb.MongoClient;
importcom.mongodb.client.MongoCollection;
importcom.mongodb.client.MongoDatabase;

public class MongoDBJDBC{
   public static voidmain( Stringargs[] ){
      try{   
         // 连接到 mongodb 服务
         MongoClientmongoClient= new MongoClient( "localhost" , 27017 );
         
         // 连接到数据库
         MongoDatabasemongoDatabase=mongoClient.getDatabase("mycol");  
         System.out.println("Connect to database successfully");
         
         MongoCollection<Document>collection=mongoDatabase.getCollection("test");
         System.out.println("集合 test 选择成功");
         //插入文档
         /** 

         * 1. 创建文档 org.bson.Document 参数为key-value的格式 

         * 2. 创建文档集合List<Document> 

         * 3. 将文档集合插入数据库集合中 mongoCollection.insertMany(List<Document>) 插入单个文档可以用 mongoCollection.insertOne(Document) 

         * */
         Documentdocument= new Document("title", "MongoDB").append("description", "database").append("likes", 100).append("by", "Fly");  
         List<Document>documents= new ArrayList<Document>();documents.add(document);collection.insertMany(documents);  
         System.out.println("文档插入成功");  
      }catch(Exceptione){
         System.err.println(e.getClass().getName() + ": " +e.getMessage() );
      }
   }
}

编译运行以上程序，输出结果如下:

Connectto database successfully集合test选择成功
文档插入成功

检索所有文档

我们可以使用 com.mongodb.client.MongoCollection 类中的 find() 方法来获取集合中的所有文档。

此方法返回一个游标，所以你需要遍历这个游标。

代码片段如下：

importorg.bson.Document;
importcom.mongodb.MongoClient;
importcom.mongodb.client.FindIterable;
importcom.mongodb.client.MongoCollection;
importcom.mongodb.client.MongoCursor;
importcom.mongodb.client.MongoDatabase;

public class MongoDBJDBC{
   public static voidmain( Stringargs[] ){
      try{   
         // 连接到 mongodb 服务
         MongoClientmongoClient= new MongoClient( "localhost" , 27017 );
         
         // 连接到数据库
         MongoDatabasemongoDatabase=mongoClient.getDatabase("mycol");  
         System.out.println("Connect to database successfully");
         
         MongoCollection<Document>collection=mongoDatabase.getCollection("test");
         System.out.println("集合 test 选择成功");
         
         //检索所有文档
         /** 

         * 1. 获取迭代器FindIterable<Document> 

         * 2. 获取游标MongoCursor<Document> 

         * 3. 通过游标遍历检索出的文档集合 

         * */  
         FindIterable<Document>findIterable=collection.find();  
         MongoCursor<Document>mongoCursor=findIterable.iterator();  
         while(mongoCursor.hasNext()){  
            System.out.println(mongoCursor.next());  
         }  
      
      }catch(Exceptione){
         System.err.println(e.getClass().getName() + ": " +e.getMessage() );
      }
   }
}

编译运行以上程序，输出结果如下:

Connectto database successfully集合test选择成功
Document{{_id=56e65fb1fd57a86304fe2692,title=MongoDB,description=database,likes=100, by=Fly}}

更新文档

你可以使用 com.mongodb.client.MongoCollection 类中的 updateMany() 方法来更新集合中的文档。

代码片段如下：

importorg.bson.Document;
importcom.mongodb.MongoClient;
importcom.mongodb.client.FindIterable;
importcom.mongodb.client.MongoCollection;
importcom.mongodb.client.MongoCursor;
importcom.mongodb.client.MongoDatabase;
importcom.mongodb.client.model.Filters;

public class MongoDBJDBC{
   public static voidmain( Stringargs[] ){
      try{   
         // 连接到 mongodb 服务
         MongoClientmongoClient= new MongoClient( "localhost" , 27017 );
         
         // 连接到数据库
         MongoDatabasemongoDatabase=mongoClient.getDatabase("mycol");  
         System.out.println("Connect to database successfully");
         
         MongoCollection<Document>collection=mongoDatabase.getCollection("test");
         System.out.println("集合 test 选择成功");
         
         //更新文档   将文档中likes=100的文档修改为likes=200collection.updateMany(Filters.eq("likes", 100), new Document("$set",new Document("likes",200)));  
         //检索查看结果
         FindIterable<Document>findIterable=collection.find();  
         MongoCursor<Document>mongoCursor=findIterable.iterator();  
         while(mongoCursor.hasNext()){  
            System.out.println(mongoCursor.next());  
         }  
      
      }catch(Exceptione){
         System.err.println(e.getClass().getName() + ": " +e.getMessage() );
      }
   }
}

编译运行以上程序，输出结果如下:

Connectto database successfully集合test选择成功
Document{{_id=56e65fb1fd57a86304fe2692,title=MongoDB,description=database,likes=200, by=Fly}}

删除第一个文档

要删除集合中的第一个文档，首先你需要使用com.mongodb.DBCollection类中的 findOne()方法来获取第一个文档，然后使用remove 方法删除。

代码片段如下：

importorg.bson.Document;
importcom.mongodb.MongoClient;
importcom.mongodb.client.FindIterable;
importcom.mongodb.client.MongoCollection;
importcom.mongodb.client.MongoCursor;
importcom.mongodb.client.MongoDatabase;
importcom.mongodb.client.model.Filters;

public class MongoDBJDBC{
   public static voidmain( Stringargs[] ){
      try{   
         // 连接到 mongodb 服务
         MongoClientmongoClient= new MongoClient( "localhost" , 27017 );

         // 连接到数据库
         MongoDatabasemongoDatabase=mongoClient.getDatabase("mycol");  
         System.out.println("Connect to database successfully");

         MongoCollection<Document>collection=mongoDatabase.getCollection("test");
         System.out.println("集合 test 选择成功");

         //删除符合条件的第一个文档collection.deleteOne(Filters.eq("likes", 200));  
         //删除所有符合条件的文档collection.deleteMany(Filters.eq("likes", 200));  
         //检索查看结果
         FindIterable<Document>findIterable=collection.find();  
         MongoCursor<Document>mongoCursor=findIterable.iterator();  
         while(mongoCursor.hasNext()){  
           System.out.println(mongoCursor.next());  
         }  
           
      }catch(Exceptione){
        System.err.println(e.getClass().getName() + ": " +e.getMessage() );
     }
   }
}

编译运行以上程序，输出结果如下:

Connectto database successfully集合test选择成功

参考文档：http://blog.csdn.net/ererfei/article/details/50857103

http://www.runoob.com/mongodb/mongodb-java.html