发一篇一个Mysql C API小型封装

用户时常会发现其实自己并不是第一个选用MySQL数据库的先驱者。”次要用于保护C布局的查询和前往。

1. #include[/size]
2. [size=13px]typedefstd::stringstring;[/size]
3. [size=13px]structMySQL_parm{
4. stringhost;
5. stringuser;
6. stringpassWord;
7. stringdatabase;
8. stringunixsock;
9. };
10. classDBSTMT;
11. classDBMysql;[/size]
12. [size=13px]classDBSTMT{
13. DBSTMT(constDBSTMT&);
14. DBSTMT&Operator=(constDBSTMT&);
15. MYSQL_STMT*stmt_;
16. public:
17. DBSTMT(pcsz_tquery,DBMysql&mysql);
18. voidexecute(){
19. if(mysql_stmt_execute(stmt_))
20. throwmysql_stmt_error(stmt_);
21. }[/size]
22. [size=13px]voidexecute(MYSQL_BIND*bind){
23. if(mysql_stmt_execute(stmt_))
24. throwmysql_stmt_error(stmt_);
25. if(mysql_stmt_bind_result(stmt_,bind)){
26. throwmysql_stmt_error(stmt_);
27. }
28. if(mysql_stmt_store_result(stmt_))
29. throwmysql_stmt_error(stmt_);
30. }[/size]
31. [size=13px]//voidexecute(){
32. //if(mysql_stmt_execute(stmt_))
33. //throwmysql_stmt_error(stmt_);
34. //}[/size]
35. [size=13px]voidbind(MYSQL_BIND*bind){
36. if(mysql_stmt_bind_param(stmt_,bind))
37. throwmysql_stmt_error(stmt_);
38. }[/size]
39. [size=13px]intfetch(){
40. returnmysql_stmt_fetch(stmt_)==0;
41. }
42. ~DBSTMT(){
43. if(stmt_){
44. mysql_stmt_close(stmt_);
45. }
46. }[/size]
47. [size=13px]};[/size]
48. [size=13px]
49. classDBMysql{
50. DBMysql(constDBMysql&);
51. DBMysql&operator=(constDBMysql&);
52. MYSQL*mysqlPtr_;
53. uint32_terrno_;
54. PRotected:
55. friendclassDBSTMT;
56. MYSQL_STMT*_createSTMT(){
57. MYSQL_STMT*ret=mysql_stmt_init(mysqlPtr_);
58. if(ret)
59. returnret;
60. errno_=mysql_errno(mysqlPtr_);
61. throwmysql_error(mysqlPtr_);
62. }
63. public:
64. constchar*strerr(){
65. returnmysql_error(mysqlPtr_);
66. }
67. DBMysql():mysqlPtr_(NULL){
68. mysqlPtr_=mysql_init(NULL);
69. if(NULL==mysqlPtr_)
70. throw"Mysql:outofmemory";
71. }
72. voidopen(constmysql_parm&parm){
73. if(!mysql_real_connect(mysqlPtr_,
74. parm.host.c_str(),
75. parm.user.c_str(),
76. parm.password.c_str(),
77. parm.database.c_str(),
78. 0,
79. parm.unixsock.c_str(),
80. 0))
81. {
82. errno_=mysql_errno(mysqlPtr_);
83. throw(mysql_error(mysqlPtr_));
84. }
85. }
86. voidclose(){
87. if(mysqlPtr_)
88. {
89. mysql_close(mysqlPtr_);
90. mysqlPtr_=NULL;
91. }
92. }
93. };
95. DBSTMT::DBSTMT(pcsz_tquery,DBMysql&mysql):stmt_(NULL){
96. stmt_=mysql._createSTMT();
97. if(!stmt_)
98. throwmysql.strerr();
99. if(mysql_stmt_prepare(stmt_,query,strlen(query)))
100. {
101. //constchar*err=
102. throwmysql_stmt_error(stmt_);
103. }
104. }
105. #defineDECL_BIND(h,n)
106. classbind_##h:publich{
107. typedefhparent;
108. MYSQL_BIND_bind[n];
109. my_bool_is_null[n];
110. unsignedlong_length[n];
111. public:
112. bind_##h(){
113. inti=0;
114. bzero(_bind,sizeof(_bind));
116. #defineBIND_BIN(x,l)
117. _bind[i].buffer_type=MYSQL_TYPE_STRING;
118. _bind[i].buffer=(char*)&(parent::x);
119. _bind[i].buffer_length=l;
120. _bind[i].is_null=_is_null+i;
121. _bind[i].length=_length+i;
122. ++i;
123. #defineBIND_INT(x)
124. _bind[i].buffer_type=MYSQL_TYPE_LONG;
125. _bind[i].buffer=(char*)&(parent::x);
126. _bind[i].buffer_length=0;
127. _bind[i].is_null=_is_null+i;
128. _bind[i].length=_length+i;
129. ++i;
130. #defineEND_BIND(h)}
131. operatorMYSQL_BIND*(){
132. return_bind;
133. }
134. };
137. 利用办法;
138. 比方想查询的内容具有以下布局
139. structaccount{
140. charuser[36];
141. bytepassword[16];
142. uint32_tstatus;
143. uint32_tid;
144. };
145. //声明查询bind布局account,参数4个
146. DECL_BIND(account,4)
147. BIND_BIN(user,32)
148. BIND_BIN(password,16)
149. BIND_INT(status)
150. BIND_INT(id)
151. END_BIND(account)
152. intmain(){
153. try{
155. DBMysqlmysql;
156. mysql_parmparm;
157. parm.host="localhost";
158. parm.user="root";
159. parm.password="test";
160. parm.unixsock="/var/lib/mysql/mysql.sock";
161. parm.database="testdb";
162. mysql.open(parm);//翻开数据库
164. DBSTMTsmt("selectuser,password,status,idfromaccount",mysql);//天生一个查询语法
165. DBSTMTsmt1("insertintoaccount(user,password,status)value(?,?,?)",mysql);//别的一个
166. //
168. bind_accountacc;
171. smt.execute(acc);//实行查询，并bind前往了局到account布局
172. while(smt.fetch()){
173. printf("%s%d%d
174. ",acc.user,acc.status,acc.id);
176. };
177. smt1.bind(acc);//bind查询参数
178. smt1.execute();//实行
182. }catch(constchar*err){
183. printf("error:%s
184. ",err);
185. }
186. }

复制代码

你可以配置MySQL运行在微小的嵌入式应用程序中，处理的数据可能不足1Mb??而你也可以用它来处理数Tb的数据。MySQL获得这种可扩展性的路径之一是通过一个人们所熟知的存储过程，这是一个运行在程序之外的微型、预编译程序。

其实可以做一下类比，Oracle等数据库产品老早就支持了java编程，而且提供了java池参数作为用户配置接口。但是现在有哪些系统大批使用了java存储过程？！连Oracle自己的应用都不用为什么？！

光写几个SQL实在叫无知。

可能有的朋友会抱怨集成的orderby，其实如果使用ranking函数,Orderby是少不了的。如果担心Orderby会影响效率，可以为orderby的字段建立聚集索引，查询计划会忽略orderby操作（因为本来就是排序的嘛）。

这一点很好的加强了profiler的功能。但是提到profiler提醒大家注意一点。windows2003要安装sp1补丁才能启动profiler。否则点击没有反应。

groupby子句可以将查询结果分组，并返回行的汇总信息Oracle按照groupby子句中指定的表达式的值分组查询结果。

having子句的作用是筛选满足条件的组，即在分组之后过滤数据，条件中经常包含聚组函数，使用having条件显示特定的组，也可以使用多个分组标准进行分组。

是否碎片会引发效率问题？这都是需要进一步探讨的东西。varbinary(max)代替image也让SQLServer的字段类型更加简洁统一。

我是新手，正在学习数据库和操作系统，深感理论的泛广，唯有一步一步来，但是又感觉时间不够，收集了很多资料却总是没能认真的看完，希望有一个讨论板块，大家共同解决，共同分享，共同努力