数据库编程——MongoDB json

09-数据库编程day05( json)

目录：

一、学习目标

二、复习

三、作业

四、

1、安装

2、的简介

3、库的操作

4、新增文档

5、查看文档

6、更新文档

7、删除文档

8、的索引

9、聚合函数

10、副本集实验

11、API 使用

（1）vs配置方法

（2）通过API连接到

（3）通过API删除文档

（4）通过API新增文档

一、学习目标

1.的安装

2.库的操作

3.文档的增删改查

4.的索引

5.的api连接数据库

二、复习

mysql约束的种类? 主键,外键,非空,唯一

mysql如何解决主键冲突问题?

table (

id INT(11) key ,

name (20) ,

(15) not null,

INT(11),

key() (id)

);

》mysql中文乱码问题

--6个字符集

○ 登录可以引起字符集变化

○ LANG环境变量修改也会引起变化

》mysql-api编程的一般流程

--初始化

--连接

….do sth

○

○ 打印表头，打印数据

--关闭连接

三、作业

》分析代码（.c）：

#include 
#include "mysql.h"
#include 
#include 
#define STRING_SIZE 50 
//create table test_table2(col1 int, col2 varchar(30), col3 smallint, col4 timestamp);
//insert into test_table2(col1,col2,col3) values(10111,'yekai',10);
//insert into test_table2(col1,col2,col3) values(10112,'yekai1',20);
//insert into test_table2(col1,col2,col3) values(10113,'yekai1',20); 
#define SELECT_SAMPLE "SELECT col1, col2, col3, col4 FROM test_table2 where col1=?"void process_fetch(MYSQL *mysql);
int main()
{MYSQL *mysql=NULL;printf("欢迎来到mysql\n");mysql = mysql_init(NULL);if(mysql == NULL){printf("init err!\n");return -1;} mysql=mysql_real_connect(mysql,"localhost","root","123456","scott",0,NULL,0);if(mysql == NULL){printf("connect to mysql err!\n");return -1;}printf("connect to mysql ok!\n");process_fetch(mysql);mysql_close(mysql);return 0;
}void process_fetch(MYSQL *mysql)
{MYSQL_STMT    *stmt;MYSQL_BIND    bind[4];//和结果集绑定MYSQL_BIND    sbind;//查询条件MYSQL_RES     *prepare_meta_result;MYSQL_TIME    ts;unsigned long length[4];int           param_count, column_count, row_count;short         small_data;int           int_data;char          str_data[STRING_SIZE];my_bool       is_null[4];/* Prepare a SELECT query to fetch data from test_table */stmt = mysql_stmt_init(mysql);if (!stmt){fprintf(stderr, " mysql_stmt_init(), out of memory\n");exit(0);}if (mysql_stmt_prepare(stmt, SELECT_SAMPLE, strlen(SELECT_SAMPLE))){fprintf(stderr, " mysql_stmt_prepare(), SELECT failed\n");fprintf(stderr, " %s\n", mysql_stmt_error(stmt));exit(0);}fprintf(stdout, " prepare, SELECT successful\n");/* Get the parameter count from the statement */param_count= mysql_stmt_param_count(stmt);fprintf(stdout, " total parameters in SELECT: %d\n", param_count);//    if (param_count != 0) /* validate parameter count */
//    {
//      fprintf(stderr, " invalid parameter count returned by MySQL\n");
//      exit(0);
//    }//bind param int sel_col1 ;memset(&sbind,0x00,sizeof(sbind));sbind.buffer_type= MYSQL_TYPE_LONG;sbind.buffer= (char *)&sel_col1;sbind.is_null= 0;sbind.length= &length[0];/* Bind the buffers */if (mysql_stmt_bind_param(stmt, &sbind)){fprintf(stderr, " mysql_stmt_bind_param() failed\n");fprintf(stderr, " %s\n", mysql_stmt_error(stmt));exit(0);}/* Fetch result set meta information */prepare_meta_result = mysql_stmt_result_metadata(stmt);if (!prepare_meta_result){fprintf(stderr," mysql_stmt_result_metadata(), returned no meta information\n");fprintf(stderr, " %s\n", mysql_stmt_error(stmt));exit(0);}/* Get total columns in the query */column_count= mysql_num_fields(prepare_meta_result);fprintf(stdout, " total columns in SELECT statement: %d\n", column_count);if (column_count != 4) /* validate column count */{fprintf(stderr, " invalid column count returned by MySQL\n");exit(0);}sel_col1 = 10111;/* Execute the SELECT query */if (mysql_stmt_execute(stmt)){fprintf(stderr, " mysql_stmt_execute(), failed\n");fprintf(stderr, " %s\n", mysql_stmt_error(stmt));exit(0);}/* Bind the result buffers for all 4 columns before fetching them */memset(bind, 0, sizeof(bind));/* INTEGER COLUMN */bind[0].buffer_type= MYSQL_TYPE_LONG;bind[0].buffer= (char *)&int_data;bind[0].is_null= &is_null[0];bind[0].length= &length[0];/* STRING COLUMN */bind[1].buffer_type= MYSQL_TYPE_STRING;bind[1].buffer= (char *)str_data;bind[1].buffer_length= STRING_SIZE;bind[1].is_null= &is_null[1];bind[1].length= &length[1];/* SMALLINT COLUMN */bind[2].buffer_type= MYSQL_TYPE_SHORT;bind[2].buffer= (char *)&small_data;bind[2].is_null= &is_null[2];bind[2].length= &length[2];/* TIMESTAMP COLUMN */bind[3].buffer_type= MYSQL_TYPE_TIMESTAMP;bind[3].buffer= (char *)&ts;bind[3].is_null= &is_null[3];bind[3].length= &length[3];/* Bind the result buffers */if (mysql_stmt_bind_result(stmt, bind)){fprintf(stderr, " mysql_stmt_bind_result() failed\n");fprintf(stderr, " %s\n", mysql_stmt_error(stmt));exit(0);}/* Now buffer all results to client */if (mysql_stmt_store_result(stmt))//预处理取回结果集{fprintf(stderr, " mysql_stmt_store_result() failed\n");fprintf(stderr, " %s\n", mysql_stmt_error(stmt));exit(0);}/* Fetch all rows */row_count= 0;fprintf(stdout, "Fetching results ...\n");while (!mysql_stmt_fetch(stmt)){row_count++;fprintf(stdout, "  row %d\n", row_count);/* column 1 */fprintf(stdout, "   column1 (integer)  : ");if (is_null[0])fprintf(stdout, " NULL\n");elsefprintf(stdout, " %d(%ld)\n", int_data, length[0]);/* column 2 */fprintf(stdout, "   column2 (string)   : ");if (is_null[1])fprintf(stdout, " NULL\n");elsefprintf(stdout, " %s(%ld)\n", str_data, length[1]);/* column 3 */fprintf(stdout, "   column3 (smallint) : ");if (is_null[2])fprintf(stdout, " NULL\n");elsefprintf(stdout, " %d(%ld)\n", small_data, length[2]);/* column 4 */fprintf(stdout, "   column4 (timestamp): ");if (is_null[3])fprintf(stdout, " NULL\n");elsefprintf(stdout, " d-d-d d:d:d (%ld)\n",ts.year, ts.month, ts.day,ts.hour, ts.minute, ts.second,length[3]);fprintf(stdout, "\n");}/* Validate rows fetched */fprintf(stdout, " total rows fetched: %d\n", row_count);
//    if (row_count != 2)
//    {
//      fprintf(stderr, " MySQL failed to return all rows\n");
//      exit(0);
//    }/* Free the prepared result metadata */mysql_free_result(prepare_meta_result);//释放结果集sel_col1 = 10112;/* Execute the SELECT query */if (mysql_stmt_execute(stmt)){fprintf(stderr, " mysql_stmt_execute(), failed\n");fprintf(stderr, " %s\n", mysql_stmt_error(stmt));exit(0);}/* Now buffer all results to client */if (mysql_stmt_store_result(stmt)){fprintf(stderr, " mysql_stmt_store_result() failed\n");fprintf(stderr, " %s\n", mysql_stmt_error(stmt));exit(0);}/* Fetch all rows */row_count= 0;fprintf(stdout, "Fetching results ...\n");while (!mysql_stmt_fetch(stmt)){row_count++;fprintf(stdout, "  row %d\n", row_count);/* column 1 */fprintf(stdout, "   column1 (integer)  : ");if (is_null[0])fprintf(stdout, " NULL\n");elsefprintf(stdout, " %d(%ld)\n", int_data, length[0]);/* column 2 */fprintf(stdout, "   column2 (string)   : ");if (is_null[1])fprintf(stdout, " NULL\n");elsefprintf(stdout, " %s(%ld)\n", str_data, length[1]);/* column 3 */fprintf(stdout, "   column3 (smallint) : ");if (is_null[2])fprintf(stdout, " NULL\n");elsefprintf(stdout, " %d(%ld)\n", small_data, length[2]);/* column 4 */fprintf(stdout, "   column4 (timestamp): ");if (is_null[3])fprintf(stdout, " NULL\n");elsefprintf(stdout, " d-d-d d:d:d (%ld)\n",ts.year, ts.month, ts.day,ts.hour, ts.minute, ts.second,length[3]);fprintf(stdout, "\n");}/* Close the statement */if (mysql_stmt_close(stmt)){fprintf(stderr, " failed while closing the statement\n");fprintf(stderr, " %s\n", mysql_stmt_error(stmt));exit(0);}}

.c

》分析代码（.h和.cpp）

四、

1、安装

》安装

1）数据库的安装

开机自动启动：

▪ /usr/local//bin/ -- /usr/local//bin/.conf

2）驱动的安装

▪ boost 安装

▪ pcre 安装 --- 正则表达式

▪ scons 编译驱动的程序

▪ 编译驱动

2、的简介

》为什么学习？

○ 扩展知识面nosql=not only sql，非关系型数据库

○ 跨平台

○ 排名（第5）

○ 非关系型里最像关系型的

○ 特点：高性能，易使用，易部署

》简介：

2007年10gen推出的产品

10gen后来更名为 M

是一个开源的,基于分布式的,面向文档存储的非关系型数据库,是非关系型数据库当 中比较像关系型数据库的

》分布式数据库：

文档：json，键值对，对应关系型数据库的一行

集合：文档的集合，多个文档组合在一起，对应关系型数据库的 表

》关系型数据库特点：

○ 表之间有关系（外键）

○ 表数据的存储是由行和列固定组成

○ 支持事务

3、库的操作

》mysql和对比

》组织结构：

库——集合（没有用户）

》库的操作：

--登录：

shell>mongo

默认连接到test库，test可以不存在

--查看有哪些库

show dbs

--退出

>exit

--指定ip，端口（登录）

>mongo :27017/mydb1

登录指令总结：mongo [ip[:port[/]]]

--切换或创建库 yekai

> use yekai

默认情况下库名不会保留，如果不做任何操作（登录仍没有！）

--如何删库？

○ 切库use

○ 删库db.()

--查看当前库名

> db

mydb2

>db.()

--查看当前库有哪些集合？两种（一般用第一种，简单）

> show

Barca

.

>show

4、新增文档

--新增/创建 一个文档 是集合名（yekai是库名）

>db..({id:1,name:'yekai',age:25,sex:'man'})

> db..find()

>db..({id:2,name:'',age:'25',sex:'woman'})

>db..({id:3,name:'',age:23,sex:'woman',like:['杀人','花生']})

>db..({id:4,name:'',age:50,sex:'man',info:{like:'drink',wuqi:''}})

总结：支持数组，info为内嵌文档。

》save与的区别：

○ 一般情况下没有区别

○ 如果指定_id，相当于，会修改原数据

--如何批量新增数据？

格式:db..find().( (x){ db..(x)} )

>db..find().((x){ db..(x)})

注意：上述反复执行，只会插入一次！

5、查看文档

》mongo常用数据类型：

数据类型 描述

字符串。存储数据常用的数据类型。在 中，UTF-8 编码的字符串才是合法的。

整型数值。用于存储数值。根据你所采用的服务器，可分为 32 位或 64 位。

布尔值。用于存储布尔值（真/假）。

双精度浮点值。用于存储浮点值。

用于将数组或列表或多个值存储为一个键。

时间戳。记录文档修改或添加的具体时间。

用于内嵌文档。

Null 用于创建空值。

符号。该数据类型基本上等同于字符串类型，但不同的是，它一般用于采用特殊符号类型的语言。

Date 日期时间。用 UNIX 时间格式来存储当前日期或时间。你可以指定自己的日期时间：创建 Date 对象，传入年月日信息。

ID 对象 ID。用于创建文档的 ID。

Data 二进制数据。用于存储二进制数据。

Code 代码类型。用于在文档中存储 代码。

正则表达式类型。用于存储正则表达式。

》练习：

--数据准备

>show

把文档内容复制粘贴执行

db.Barca.insert({_id:'10001',name:'messi',number:10,age:29,pos:'CF',height:169,weight:68,lgdata:[40,30]})
db.Barca.insert({_id:'10002',name:'neymar',number:11,age:24,pos:'CF',height:176,weight:55,lgdata:[20,15]})
db.Barca.insert({_id:'10003',name:'suarez',number:9,age:29,pos:'CF',height:182,weight:82,lgdata:[40,15]})
db.Barca.insert({_id:'10004',name:'Ter Stegen',number:1,age:24,pos:'GK',height:193,weight:82})
db.Barca.insert({_id:'10005',name:'pique',number:3,age:29,pos:'CB',height:195,weight:82})
db.Barca.insert({_id:'10006',name:'rakitic',number:4,age:28,pos:'MF',height:182,weight:72})
db.Barca.insert({_id:'10007',name:'busquets',number:5,age:28,pos:'CF',height:182,weight:82})
db.Barca.insert({_id:'10008',name:'iniesta',number:8,age:31,pos:'CF',height:182,weight:82})
db.Barca.insert({_id:'10009',name:'mascherano',number:14,age:32,pos:'CF',height:182,weight:82})
db.Barca.insert({_id:'10010',name:'alba',number:18,age:27,pos:'SB',height:182,weight:82})
db.Barca.insert({_id:'10011',name:'rebeto',number:20,age:24,pos:'SB',height:182,weight:82})
db.Barca.insert({_id:'10012',name:'munir',number:17,age:24,pos:'SS',height:169,weight:68})
db.Barca.insert({_id:'10013',name:'Mathieu',number:24,age:32,pos:'CB',height:176,weight:55})
db.Barca.insert({_id:'10014',name:'sandero',number:29,age:29,pos:'CF',height:182,weight:82})
db.Barca.insert({_id:'10015',name:'Cillessen',number:13,age:30,pos:'GK',height:185,weight:82})
db.Barca.insert({_id:'10016',name:'Denis Suayes',number:18,age:31,pos:'MF',height:169,height:185,weight:82})
db.Barca.insert({_id:'10017',name:'Samuel Umtiti',number:2,age:31,pos:'CB',height:171,weight:71})
db.Barca.insert({_id:'10018',name:'wheremalun',number:23,age:28,height:182,weight:82})
db.Barca.insert({_id:'10019',name:'rafnia',number:12,age:24,pos:'MF',height:182,weight:82})
db.Barca.insert({_id:'10020',name:'vhalirvic',number:19,age:23,pos:'null,height:182,weight:82})
db.Barca.insert({_id:'10021',name:'Lucas Digne',number:21,age:22,pos:'SB',height:182,weight:82})
db.Barca.insert({_id:'10022',name:'Aleix Vidal',number:26,age:24,pos:'SB',height:182,weight:82})

.txt

>show

>db.Barca.find()

》语法:db..find(,)

--查看巴萨队内全部球员 * from Barca ;

>.=30 ——注意：默认显示20，改为30

>db.Barca.find()

--查看梅西的详细信息 * from Barca where name='messi'

>db.Barca.find({name:'messi'})

--查看年龄为29,并且是踢中后卫(pos为CB)的球员 * from Barca where age=24 and pos='MF'; >db.Barca.find({age:29,pos:'CB'})

--查看年龄大于25,并且是中场的球员（MF）(需要知道小于lt,大于gt,小于等于lte,大于等于gte,不等 于ne)

$gt = than 大于

$lt = less than 小于

$lte = less than equal 小于等于

$gte = than equal 大于等于

$ne = not equal 不等于

>db.Barca.find({ age:{$gt:25},pos:'MF' })

——注意：上述查询只返回一条记录,到一个就返回

>db.Barca.find({ age:{$gt:25},pos:'MF' }).()

--显示球员姓名,年龄,位置 ——注意：显示部分列

>db.Barca.find({},{name:1,age:1,pos:1})

>db.Barca.find({},{name:1,age:1,pos:1,_id:0}) ——注意：不显示id

--显示球员的不同年龄 age from Barca;

>db.Barca.('age')

--显示进球数超过30的球员信息 的第一个值代表进球数,第二个值代表助攻数 （查找数组中的元素）

>db.Barca.find( { ".0":{$gt:30} })

--显示助攻数超过20的球员信息

>db.Barca.find( { ".1":{$gt:20} })

--显示年龄是24或者29的球员信息 * from Barca where age=24 or age =29;

>db.Barca.find( { $or:[{age:24},{age:29}] })

>db.Barca.find( { age:{$in:[24,29]})

--显示年龄不是24或者29的球员信息

>db.Barca.find( { age:{$nin:[24,29]} })

--显示位置为空的球员信息pos is null

>db.Barca.find( { pos:null})

——注意：没有该字段也符合条！

--将球员按照年龄排序

>db.Barca.find().sort({age:1}) （默认升序）

>db.Barca.find().sort({age:-1})

--显示第11名球员信息

——注意：skip代表跳过的记录数，limit代表取记录数

>db.Barca.find({name:''}) ——看文档，查看第11个是谁，不推荐。

>db.Barca.find().skip(10).limit(1)

6、更新文档

：如果条件不存在是否新增记录，默认是false （不更新）

multi：是否修改多条，默认是false，只更新找到的第一条

--将的位置修改为中场MF

> db.Barca.({name:''},{$set:{pos:'MF'}})

--将的位置修改为null

>db.Barca.({name:''},{$set:{pos:null}})

--将 的年龄改为25岁,位置改成SB

>db.Barca.({name:''},{$set:{pos:'SB',age:25}})

--将pos为null的球员信息修改为pos=MF

>db.Barca.({pos:null},{$set:{pos:'MF'}})

--将年龄为24的球员年龄全部修改为25

>db.Barca.({age:24},{$set:{age:25}})

——注意：上述语句只更改一条

>db.Barca.({age:24},{$set:{age:25}},{:false,multi:true})

--使用，如果不存在新增

>db.Barca.({age:24},{$set:{age:25}},{:true,multi:true})

》操作： 集合

--如果不指定set，直接覆盖

>db..({id:1},{name:'',age:25})

所以，set相当于精确修改，可以指定具体字段

7、删除文档

》语法：

是否只删除一个，默认是false（全删）

默认使用. 仅仅抛出网络异常，没有服务器错误异常

--删除球员年龄为25的球员信息

>db.Barca.({age:25})

--删除集合（创建集合：第一条语句）

>db.Barca.drop()

》查看时间：

>Date()

>()

如何使用？

8、的索引

》索引作用：提高查询效率

默认主键自动创建了索引！

--创建索引

> db.Barca.({name:1})

--查看执行计划

如果显示的是""："" 代表未使用索引

> db.Barca.find({age:24}).()

如果显示的是"" ： 代表使用索引

> db.Barca.find({name:'messi'}).()

“”:“”表示本次查询没有使用索引；

“ ”表示使用了name上的索引；

“”表示是否使用了多键索引；

“n”：本次查询返回的文档数量；

“”:表示按照索引指针去磁盘上实际查 找实际文档的次数；

”“:如果没有索引，这个数字就是查找过的索 引条目数量；

“”：是否对结果集进行了排序；

“”：是否利用索引就能完成查询；

db.Barca.find( {name:''},{_id:0,name:1} ).( )

“”:如果在查询的过程中有写操作，查询就会暂 停；这个字段代表在查询中因写操作而暂停的次数；

“ ”：本次查询花费的毫秒数，数字越小说明查 询的效率越高；

“”：这个字段描述索引的使用情况，给出 索引遍历的范围。

"" : 是否使用和索引过滤；

--删除索引

> db.Barca.({name:1})

9、聚合函数

--显示集合的记录总数

>db.Barca.find().count()

--求各个位置的最小年龄 pos,min(age) from Barca group by pos

>db.Barca.({ $group:{_id:"$pos",:{$min:"$age"}} }) （为聚合函数）

——需要使用group关键字

——可以使用>db.Barca.find({pos:'SS'}) 查看是否统计正确

--求各个位置的最大年龄

>db.Barca.({ $group:{_id:"$pos",:{$max:"$age"}} })

--求各个位置的平均年龄

>db.Barca.({ $group:{_id:"$pos",:{$avg:"$age"}} })

--求各个位置的年龄和

>db.Barca.({ $group:{_id:"$pos",:{$sum:"$age"}} })

--统计各个位置的人数 count(*),pos from Barca group by pos;

>db.Barca.({ $group:{_id:"$pos",count:{$sum:1}} })

——可以使用>db.Barca.find({pos:'SB'})查看是否统计正确

--统计不同位置不同年龄的人数 group by age，pos

>db.Barca.({ $group:{_id:{age:"$age",pos:"$pos"},count:{$sum:1}} })

——可以使用>db.Barca.find({age:24,pos:'SB'}) 查看是否统计正确

10、副本集实验

》实验：

准备运行1个主节点，2个从节点，从节点中其中是一个是仲裁节点(Arb)。

--登录root用户,创建三个目录

$mkdir –p /data/node1

$mkdir –p /data/node2

$mkdir –p /data/

--启动三个服务

$nohup /usr/local//bin/ -- -- /data/node1/ --port 9927 -- 1024 &

$nohup /usr/local//bin/ -- -- /data/node2/ --port 9928 -- 1024 &

$nohup /usr/local//bin/ -- -- /data// --port 9929 -- 1024 &

其中是副本集的名称，节点必须相同，–指定数据库储存路径，–port指定侦听端口，–指定数据同步之前的缓存的空间大小，暂时指定1G。（可以设置小点，如512。）

可以使用（shell>ps aux|grep ）查看启动三个服务进程

选择9927端口的实例为主节点，进入9927的shell:

$mongo :9927

--初始化副本集需要配置表，申明配置表如下:

> = {_id: "", : []}

注意_id和副本集启动的共享名称一致。下面来逐步添加节点的数据信息：

>..push({_id: 0, host: ":9927"})

>..push({_id: 1, host: ":9928"})

>..push({_id: 2, host: ":9929", : true})

也可以使用rs.add和rs.函数来实现同样的操作。然后需要用这个表作为参数初始化副本集，在9927端口的shell执行：

> rs.()

"info" : " now saved . come in about a .",

"ok" : 1

返回ok为1表示初始化成功，三个节点互相检测通信，需要1分钟左右(反应够慢的 ^-)，可以查看三个终端窗口的信息确认，完成通信后，在9927端口的shell回车执行命令确认配置：

复制代码

> rs.()

{"setName" : "application","ismaster" : true,"secondary" : false,"hosts" : ["localhost:9927","localhost:9928"],"arbiters" : ["localhost:9929"],"primary" : "localhost:9927","me" : "localhost:9927","maxBsonObjectSize" : 16777216,"maxMessageSizeBytes" : 48000000,"localTime" : ISODate("2016-09-04T05:23:09.359Z"),"ok" : 1
} 

> rs.()

注意到9927端口的实例是true，为false，hosts有2个实例，有1个元素，关键key表示了主节点，通信完成几次回车后可以看到9927的端口的实例shell的提示符已经改变，更改为:，查看更详细的信息：

:> rs.()

application:PRIMARY> rs.status()
{"set" : "application","date" : ISODate("2016-09-04T05:24:16Z"),"myState" : 1,"members" : [{"_id" : 0,"name" : "localhost:9927","health" : 1,"state" : 1,"stateStr" : "PRIMARY","uptime" : 430,"optime" : Timestamp(1472966482, 1),"optimeDate" : ISODate("2016-09-04T05:21:22Z"),"self" : true},{"_id" : 1,"name" : "localhost:9928","health" : 1,"state" : 2,"stateStr" : "SECONDARY","uptime" : 170,"optime" : Timestamp(1472966482, 1),"optimeDate" : ISODate("2016-09-04T05:21:22Z"),"lastHeartbeat" : ISODate("2016-09-04T05:24:14Z"),"lastHeartbeatRecv" : ISODate("2016-09-04T05:24:15Z"),"pingMs" : 0,"syncingTo" : "localhost:9927"},{"_id" : 2,"name" : "localhost:9929","health" : 1,"state" : 7,"stateStr" : "ARBITER","uptime" : 170,"lastHeartbeat" : ISODate("2016-09-04T05:24:14Z"),"lastHeartbeatRecv" : ISODate("2016-09-04T05:24:15Z"),"pingMs" : 0}],"ok" : 1
}

:> rs.()

显示了每个节点的健康状况，名称，启动的时间，节点的类型等。查看当前副本集的配置表：

:> rs.conf()

pplication:PRIMARY> rs.conf()
{"_id" : "application","version" : 1,"members" : [{"_id" : 0,"host" : "localhost:9927"},{"_id" : 1,"host" : "localhost:9928"},{"_id" : 2,"host" : "localhost:9929","arbiterOnly" : true}]
}

:> rs.conf()

》开始插入测试数据

:> db.users.({:'yekai',age:34})

:> db.users.find()

{ "_id" : ("f587"), "" : "yekai", "age" : 34 }

进入9928从节点，执行查看集合

$mongo :9928

:> show ;

Sun Sep 4 13:39:46.607 error: { "$err" : "not and =false", "code" : 13435 } at src/mongo/shell/query.js:128

发现shell抛出了异常，显示为false，当前副本集需要明确从节点参数，执行函数：

:> rs.()

:> show ;

.

users

--查看数据

:> db.users.find()

{ "_id" : ("f587"), "" : "yekai", "age" : 34 }

--从节点执行操作

:> db.users.({:'',age:25})

not

显示not ,代表当前从节点只读.

--进入9929端口，可以看到仲裁节点的提示符号

@:~$ mongo :9929

shell : 2.4.9

to: :9929/test

:>

》执行故障转移测试:

1）可以杀掉9927的主节点

--再在从节点执行一下查询,发现从节点意见自己变成主节点

:> db.users.find()

{ "_id" : ("f587"), "" : "yekai", "age" : 34 }

--再次执行插入操作

:> db.users.({:'',age:25})

:> db.users.find()

{ "_id" : ("f587"), "" : "yekai", "age" : 34 }

{ "_id" : ("fa09"), "" : "", "age" : 25 }

已经可以插入成功

2）再将9927上线

--9927将变为从节点

@:~$ mongo :9927

shell : 2.4.9

to: :9927/test

:> show ;

Sun Sep 4 13:55:33.333 error: { "$err" : "not and =false", "code" : 13435 } at src/mongo/shell/query.js:128

:> rs.()

:> show

.

users

--查看数据

:> db.users.find()

{ "_id" : ("f587"), "" : "yekai", "age" : 34 }

{ "_id" : ("fa09"), "" : "", "age" : 25 }

仲裁节点的作用是协调选举，监测系统运行状态，提供节点互相通讯的数据信息。

11、API 使用

》文件准备：

\\mongo\\mongo文件夹及目录下pch.h、.h、.h

   /** @file pch.h : include file for standard system include files,*  or project specific include files that are used frequently, but*  are changed infrequently*//*    Copyright 2009 10gen Inc.**    Licensed under the Apache License, Version 2.0 (the "License");*    you may not use this file except in compliance with the License.*    You may obtain a copy of the License at**    http://www.apache.org/licenses/LICENSE-2.0**    Unless required by applicable law or agreed to in writing, software*    distributed under the License is distributed on an "AS IS" BASIS,*    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.*    See the License for the specific language governing permissions and*    limitations under the License.*/#ifndef MONGO_PCH_H
#define MONGO_PCH_H// our #define macros must not be active when we include
// system headers and boost headers
#include "mongo/client/undef_macros.h"#include "mongo/platform/basic.h"#include 
#include 
#include 
#include 
#include 
#include 
#include 

pch.h

/** @file server.hThis file contains includes commonly needed in the server files (mongod, mongos, test).  It is *NOT* included in the C++ client; i.e. this is a very good place for global-ish things that you don't need to be in the client lib.Over time we should move more here, and more out of pch.h.  And get rid of pch.h at some point.
*/#pragma once#if !defined(MONGO_EXPOSE_MACROS)
# error this file is for mongo server programs not client lib
#endif#include 

.h

/**
*    Copyright (C) 2008 10gen Inc.
*
*    This program is free software: you can redistribute it and/or  modify
*    it under the terms of the GNU Affero General Public License, version 3,
*    as published by the Free Software Foundation.
*
*    This program is distributed in the hope that it will be useful,
*    but WITHOUT ANY WARRANTY; without even the implied warranty of
*    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
*    GNU Affero General Public License for more details.
*
*    You should have received a copy of the GNU Affero General Public License
*    along with this program.  If not, see .
*/#pragma once
#ifndef _WIN32_WINNT            // Allow use of features specific to Windows Vista or later.
#define _WIN32_WINNT 0x0600     // Change this to the appropriate value to target other versions of Windows.
#endif

.h

（1）vs配置方法

打开，新建项目：选择“ C++”，右侧选择“空项目”，名称：，位置改为所在目录（我的为 F:\\06-数据库编程day05( json)\4-源码\）；

创建成功后，在“”右键选择“属性”，选择“VC++目录”进行配置：选择“包含目录”，在其后加入到一级的目录（我的为 F:\\06-数据库编程day05( json)\4-源码\\mongo\）；

注意：以上把mongo的头文件配置为绝对路径；推荐使用相对路径：寻找自己的相对路径 ..\..\mongo\

（2）通过API连接到

类（通过VS可以方便的查看API函数）

》构造函数

(bool =false, * cp=0, =0)

○ 是否自动重连，默认false

○ cp 不需要关心

○ 超时时间，单位是秒

》连接函数

bool (const char * , & )

○ 主机 类似这样： 127.0.0.1 , 127.0.0.1:5555

○ 错误信息，传出

在“”右键添加源文件：main.cpp，然后编写代码：

#include 
#include 
#include using namespace std;
using namespace mongo;int main(int argc,char *argv[])
{//构造连接DBClientConnection conn(false,0,3);std::string errmsg;if (!conn.connect("localhost", errmsg)){cout << "connect to mongo err" << endl;return -1;}cout << "connect ok" << endl;return 0;
}

将main.cpp传至Linux上，然后编译

>g++ -o main main.cpp - - - -ns -L/home///boost/lib -L/home///mongo/lib -I/home///mongo/ -I/home///boost/

>./main

（3）通过API删除文档

》删除文档

void ( const &ns , Query q , bool = 0 )

○ ns 库名.集合名

○ q 是一个查询条件

○ 是否删除一条，默认false

》Query 是一个类

○ Query(const char * json);构造函数，可以构造

--在VS中更改main.cpp

#include 
#include 
#include using namespace std;
using namespace mongo;int main(int argc,char *argv[])
{//构造连接DBClientConnection conn(false,0,3);std::string errmsg;if (!conn.connect("localhost", errmsg)){cout << "connect to mongo err" << endl;return -1;}cout << "connect ok" << endl;//remove//删除id>=2 {id:{$gte:2}}Query qry("{id:{$gte:2}}");conn.remove("yekai.biancheng", qry);return 0;
}

原终端删除前后数据对比：（将main.cpp传至Linux上，然后打开另一个终端重新编译执行）

（4）通过API新增文档

》新增文档

void ( const &ns , obj , int flags=0)

○ ns 库名.集合名

○ obj对象

》新增的核心问题—如何构造？

可以构造

》增加一个字符型的key：value

(const & , const char *str)

obj() 可以返回对象

/** Use BSON macro to build a from a

e.g.,

BSON( "name"