使用指引产品文档

Size: px

Start display at page:

Download "使用指引产品文档"

灿宣
6 years ago
Views:

1 云数据库 MongoDB 使用指引产品文档

2 版权声明腾讯云版权所有本文档著作权归腾讯云单独所有, 未经腾讯云事先书面许可, 任何主体不得以任何形式复制修改抄袭传播全部或部分本文档内容商标声明及其它腾讯云服务相关的商标均为腾讯云计算 ( 北京 ) 有限责任公司及其关联公司所有本文档涉及的第三方主体的商标, 依法由权利人所有服务声明本文档意在向客户介绍腾讯云全部或部分产品服务的当时的整体概况, 部分产品服务的内容可能有所调整您所购买的腾讯云产品服务的种类服务标准等应由您与腾讯云之间的商业合同约定, 除非双方另有约定, 否则, 腾讯云对本文档内容不做任何明示或模式的承诺或保证第 2 页共 23 页

3 文档目录文档声明... 2 连接示例... 4 Shell 连接示例... 5 PHP 连接示例... 6 Node.js 连接示例 Java 连接示例 Python 连接示例查看及监控实例数据重连机制导入导出第 3 页共 23 页

4 连接示例实例初始化后, 可以通过各语言驱动进行访问数据库, 进行数据存取操作 ( 注 : 需要使用 CVM 通过内网进行访问 ) Shell 连接示例 PHP 连接示例 Node.js 连接示例 mongoose 示例 Java 连接示例 Python 连接示例重连机制第 4 页共 23 页

5 Shell 连接示例 Shell 命令 : mongo : u rwuser --password= a --authenticationmechanism=mongodb-cr 示例 : 第 5 页共 23 页

6 PHP 连接示例相关帮助在 PHP 里, 有两套驱动可用于连接操作 MongoDB 数据库, 它们分别是 : mongodb(php 官网文档 ) 和 mongo(php 官网文档 ) 推荐 mongodb, 但需要 PHP 5.4 及以上版本 ; mongo 比较老旧, 但也可以用, 如果要用请选择 1.6 版本下面我们分别用上述两个驱动演示一下连接腾讯云 MongoDB 并进行读写 : 使用 mongodb 驱动连接示例示例代码 : <?php // 建立连接 $manager = new MongoDB\Driver\Manager( 'mongodb://rwuser: a@ :27017/admin?authmechanism=mongodb- CR' ); // 准备写入数据 $document1 = [ 'username' => 'lily', 'age' => 34, ' ' => 'lily#qq.com' ]; // 驱动处理数据, 这里可以看到 MongoDB 的 _id 是驱动生成的 $bulk = new MongoDB\Driver\BulkWrite; $_id1 = $bulk->insert($document1); // 打印 _id 查看 print_r($_id1); 第 6 页共 23 页

7 $result = $manager->executebulkwrite('testdb.testcollection', $bulk); // 或者使用下面的方法确保数据写入到大多数节点 // $writeconcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern:: MAJORITY, 1000); // $result = $manager->executebulkwrite('testdb.testcollection', $bulk, $writeco ncern); // 查询 $filter = ['username' => 'lily']; $query = new MongoDB\Driver\Query($filter); $rows = $manager->executequery('testdb.testcollection', $query); // 也可以选择优先从从库读哦, 具体请参阅文档 MongoDB\Driver\Query 的选项部分 ( 很强大 ) foreach($rows as $r){ print_r($r); 输出 : MongoDB\BSON\ObjectID Object ( [oid] => 577a e2f36fc4b2831 ) stdclass Object ( [_id] => MongoDB\BSON\ObjectID Object ( [oid] => 577a e2f36fc4b2831 ) [username] => lily [age] => 34 第 7 页共 23 页

8 [ ] => ) 使用 mongo 驱动连接示例示例代码 : <?php // 推荐使用 URI 的方式连接 $connection = new MongoClient( "mongodb://rwuser: a@ :27017/admin?authmechanism=mongodb-cr"); /* // 或者这样也可以 $connection = new MongoClient("mongodb:// :27017/admin", array( "username" => "rwuser", "password" => "password", "authmechanism" => "MONGODB-CR", ) ); */ $db = $connection->tsdb; $collection = $db->table1; $q = array( 'id' => 1, 'test1' => 'xxx', 'ss' => 'xxxxxxxx', ); $collection->save($q); $one = $collection->findone(); 第 8 页共 23 页

9 var_dump($one);?> 输出 : array(4) { ["_id"]=> object(mongoid)#7 (1) { ["$id"]=> string(24) "5673beed041ee2b1458b4567" ["id"]=> int(1) ["test1"]=> string(3) "xxx" ["ss"]=> string(8) "xxxxxxxx" 第 9 页共 23 页

10 Node.js 连接示例相关帮助 Node.js MongoDB 驱动文档 : Shell: npm install mongodb sprintf-js --save ( 如遇安装不成功可以尝试更换源,npm config set registry ) npm init Node.js 原生示例代码 'use strict'; var mongoclient = require('mongodb').mongoclient, sprintf = require("sprintf-js").sprintf, assert = require('assert'); var username = 'rwuser', password = ' a', host port = ' ', = '27017', dbname = 'havefun'; // 拼接 URI, 注意需要使用鉴权参数 authmechanism=mongodb-cr var url = sprintf( 'mongodb://%s:%s@%s:%d/%s?aut hmechanism=mongodb-cr', username, password, host, port, dbname); console.info("url:", url); 第 10 页共 23 页

11 mongoclient.connect(url, function(err, db) { assert.equal(null, err); console.log("connected correctly to server"); // 连接成功, 选择一个集合 ( 表 ) var col = db.collection('democol'); // 插入数据 col.insertone( { a: 1, something: "yy", // 可选参数 //{ // w: 'majority' // 开启大多数模式, 保证数据写入 Secondary 节点 //, function(err, r) { assert.equal(null, err); // 断言写入成功 assert.equal(1, r.insertedcount); // 查询数据 col.find().toarray(function(err, docs) { assert.equal(null, err); console.info("docs:", docs); db.close(); ); ); ); 第 11 页共 23 页

12 输出 : [root@vm_2_167_centos node]# node index.js url: mongodb://rwuser: a@ :27017/havefun?authmechanism=mongodb- CR Connected correctly to server docs: [ { _id: 567a1bf b3ff0b42a, a: 1, something: 'yy' ] Node.js mongoose 连接示例 var dburi = "mongodb://" + user + ":" + password + "@" + host + ":" + port + "/" + dbname; var opts = { auth: { authmechanism: 'MONGODB-CR' ; var connection = mongoose.createconnection(dburi, opts); 第 12 页共 23 页

13 Java 连接示例 Java MongoDB 驱动文档 Java Jar 包下载请选择 3.0 以上版本下载 Java 示例代码 : package mongodbdemo; import org.bson.*; import com.mongodb.*; import com.mongodb.client.*; public class MongodbDemo { public static void main(string[] args) { String mongouri = "mongodb://rwuser: a@ :27017/admin?authmechanism=mongodb-cr"; MongoClientURI connstr = new MongoClientURI(mongoUri); MongoClient mongoclient = new MongoClient(connStr); try { // 使用名为 someonedb 的数据库 MongoDatabase database = mongoclient.getdatabase("someonedb"); // 取得集合 / 表 someonetable 句柄 MongoC ollection<document> collection = database.getcollection("someonetable"); // 准备写入数据 Document doc = new Document(); doc.append("key", "value"); doc.append("username", "jack"); 第 13 页共 23 页

14 doc.append("age", 31); // 写入数据 collection.insertone(doc); System.out.println("insert document: " + doc); // 读取数据 BsonDocument filter = new BsonDocument(); filter.append("username", new BsonString("username")); MongoCursor<Document> cursor = collection.find(filter).iterator(); while (cursor.hasnext()) { System.out.println("find document: " + cursor.next()); finally { // 关闭连接 mongoclient.close(); 输出 : INFO: Opened connection [connectionid{local Value:2, servervalue:67621] to :27017 insert document: Document{{key=value, username=jack, age=31, _id=56a6ebb565b33b7 71f9826dd find document: Document{{_id=56a b33b2e7ca150ba, key=value, username=jack, age=31 Jan 26, :44:53 AM com.mongodb.diagnostics.logging.jullogger log INFO: Closed connection [connectionid{local Value:2, servervalue:67621] to :27017 because the pool has been clo sed. 第 14 页共 23 页

15 第 15 页共 23 页

16 Python 连接示例 Python 驱动下载 pymongo Python 示例代码 1: #!/usr/bin/python import pymongo import random mongodburi = 'mongodb://rwuser: test@ :27017/admin?authmechanism=mongodb-cr' client = pymongo.mongoclient(mongodburi) db = client.someonedb #db = client.tage db.authenticate("someonedb","test") db.user.drop() db.user.save({'id':1,'name':'kaka','sex':'male') for id in range(2,10): name = random.choice(['r9','cat','owen','lee','j']) sex = random.choice(['male','female']) db.user.insert({'id':id,'name':name,'sex':sex) content = db.user.find() for i in content: print i Python 示例代码 2: #!/usr/bin/python 第 16 页共 23 页

17 import pymongo mongodburi = 'mongodb://rwuser: a@ :27017/admin?authmechanism=mongodb-cr' client = pymongo.mongoclient(mongodburi) db = client.someonedb inserted_id = db.somecoll.insert_one({"somekey":"yiqihapi").inserted_id print inserted_id for doc in db.somecoll.find(dict(_id=inserted_id)): print doc for doc in db.somecoll.find({"somekey":"yiqihapi"): print doc 输出 : e101e2f6d699b37ef {u'somekey': u'yiqihapi', u'_id': ObjectId(' e101e2f6d699b37ef') {u'somekey': u'yiqihapi', u'_id': ObjectId(' e101e2f6d699b37ef') 第 17 页共 23 页

18 查看及监控实例数据详细信息 & 监控数据查看点击实例名可以进入详细信息和监控数据查看页面第 18 页共 23 页

19 第 19 页共 23 页

20 重连机制说明腾讯云 MongoDB 数据库服务提供的不是简单的 mongod 访问, 给到用户访问的是一个负载均衡 IP, 此 IP 后面是连接到一系列类似 mongos 一样存在的路由接入层客户端驱动会透过负载均衡 IP 与接入机建立一个长连接, 当此连接处于长期间活跃状态时, 我们不会对其做任何干预, 但是当长连接闲置时间超过 1 天时 ( 此时间会随着版本优化而调整 ), 路由接入层会踢掉该连接一般来说, 客户端驱动会实现一个自动重连的过程, 但是也有部分语言的驱动并没有实现对于没有实现自动重连的语言驱动, 当用户使用一个已经被踢掉的连接来尝试与腾讯云 MongoDB 服务通信时可能会得到 Rem ote server has closed the connection 之类的错误信息所以得手动进行重连, 这里给出一个 PHP 重连的 demo 基于 php mongo 驱动的重连实现 <?php function getconnection() { $connection = false; $uri = 'mongodb://rwuser: a@ :27017/admin?authmechanism=mongodb-cr'; $maxretries = 5; for( $counts = 1; $counts <= $maxretries; $counts++ ) { try { $connection = new MongoClient($uri); catch( Exception $e ) { // 或者根据需要使用下面的 catch 代码行, 注意那一个 \, 某些框架使用命名空间时需要用到 // catch( \Exception $e ) { continue; break; return $connection; 第 20 页共 23 页

21 $connection = getconnection(); if($connection) { $db = $connection->testdb; $collection = $db->testcollection; $one = $collection->findone(); var_dump($one); 第 21 页共 23 页

22 导入导出导入导出可以使用 mongo 官方套件 : 导出 mongodump mongoexport 导入 mongorestore mongoimport 一般来说, 要进行整库导出导入时使用 mongodump 和 mongorestore, 这一对组合的效率要高一些要进行部分数据导入导出时可以使用 mongoexport 和 mongoimport 以下是 shell 命令示例 mongodump 和 mongorestore 导出 : mongodump -h port= u rwuser -p a --authe nticationmechanism =MONGODB-CR --authenticationdatabase=admin -d mydb -o /data/dump_file 导入 : mongorestore -h port= u rwuser -p a --authenticationmechanism=mongodb- CR --authenticationdatabase=admin --dir=/data/dump_file mongoexport 和 mongoimport 导出 : 第 22 页共 23 页

23 Powered by TCPDF ( 使用指引产品文档实际使用时可以加上 -f 参数指定需要的字段,-q 参数指定一个查询条件来限定要导出的数据导入 : mongoexport -h port= u rwuser -p a --authe nticationmechanism =MONGODB- CR --authenticationdatabase=admin -d mydb -c mycoll -o /data/data1.json mongoimport -h port= u rwuser -p a --authe nticationmechanism =MONGODB- CR --authenticationdatabase=admin -d mydb -c mycoll --file=/data/data1.json 第 23 页共 23 页

Domain Management产品文档

Domain Management产品文档腾讯云Content Delivery Network Domain Management 产品文档版权声明 2015-2016 腾讯云版权所有本文档著作权归腾讯云单独所有未经腾讯云事先书面许可任何主体不得以任何形式复制修改抄袭传播全部或部分本文档内容商标声明及其它腾讯云服务相关的商标均为腾讯云计算北京有限责任公司及其关联公司所有本文档涉及的第三方主体的商标依法由权利人所有