C++ 连接mysql源代码

#include <iostream> #include <Windows.h> #include <MySQL/mysql.h> using namespace std; #pragma comment(lib,"../lib/libmysql.lib") int main() { MYSQL *mydata = mysql_init((MYSQL*) 0); MYSQL_RES *result = NULL ;//保存返回结果 //初始化数据库 if (0 == mysql_library_init(0, NULL, NULL)) { cout << "mysql_library_init() succeed" << endl; } else { cout << "mysql_library_init() failed" << endl; return -1; } //在连接数据库之前，设置额外的连接选项 //可以设置的选项很多，这里设置字符集，否则无法处理中文 if (0 == mysql_options(mydata, MYSQL_SET_CHARSET_NAME, "gbk")) { cout << "mysql_options() succeed" << endl; } else { cout << "mysql_options() failed" << endl; return -1; } //连接数据库 if (NULL != mysql_real_connect(mydata, "localhost", "root", "123456", "MySQL", 3306, NULL, 0)) { cout << "mysql_real_connect() succeed" << endl; } else { cout << "mysql_real_connect() failed" << endl; } //创建表 string sqlstr ="CREATE TABLE hjl(name varchar(8), age integer, hometown varchar(18) )"; if (0 == mysql_query(mydata, sqlstr.c_str())) { cout <<"create table seccess"<<endl; } else { cout<<"create table error"<<endl; } //插入语句 for (int i=0; i<30;i++) { sqlstr = "insert into hjl values('lyj',22,'chengdu') "; if (0 == mysql_query(mydata, sqlstr.c_str())) { cout <<"insert seccess"<<endl; } else { cout<<"insert error"<<endl; } } //显示刚刚插入的数据 sqlstr = "select * from hjl"; if (0 == mysql_query(mydata, sqlstr.c_str())) { cout <<"show table seccess"<<endl; result = mysql_store_result(mydata); int rowcount = mysql_num_rows(result); cout<<"插入数据行数:"<<rowcount<<endl; //取得并打印各段的名字 unsigned int fieldcount=mysql_num_fields(result); MYSQL_FIELD *field = NULL; for (unsigned int i=0; i<fieldcount;i++) { field = mysql_fetch_field_direct(result,i); cout<<field->name<<"/t/t"; } cout<<endl<<endl; //打印各列 MYSQL_ROW row = NULL; row = mysql_fetch_row(result); while (NULL != row) { for (unsigned int i=0; i<fieldcount; i++) { cout<<row[i]<<"\t\t"; } cout<<endl; row = mysql_fetch_row(result); } } else { cout<<"show table error"<<endl; } //删除刚才建的表 sqlstr="DROP TABLE hjl"; if(0==mysql_query(mydata,sqlstr.c_str())) { cout<<"mysql_query() drop table succeed"<<endl; } else { cout<<"mysql_query() drop table failed"<<endl; mysql_close(mydata) ; return -1; } //释放句柄 mysql_free_result(result); mysql_close(mydata); mysql_server_end(); system("pause"); }