這里復(fù)制的

http://www.bitscn.com/pdb/mysql/201407/226252.html

一、環(huán)境配置

1，裝好mysql，新建一個(gè)C++控制臺(tái)工程(從最簡單的弄起，這個(gè)會(huì)了，可以往任何c++工程移植)，在vs2010中設(shè)置，工程--屬性--VC++目錄--包含目錄，將mysql server\include的絕對路徑添加進(jìn)去，例如C:\Program Files\MySQL\MySQL Server 5.6\include。將mysql server\lib文件夾下的libmysql.lib和libmysql.dll拷貝到工程目錄下。

(也可以將include文件整個(gè)拷貝到工程目錄下，然后在VC++目錄里面設(shè)置相對路徑)

如果安裝的是wamp這種集成開發(fā)包，找不到include和lib也沒關(guān)系，隨便找個(gè)mysql免安裝版根目錄下的include文件夾和libmysql.lib以及l(fā)ibmysql.dll拷貝到工程目錄，然后設(shè)置VC++目錄即可。

新建一個(gè)數(shù)據(jù)庫test，建立一張表user，如圖

注意有些字段需要改字符編碼為utf8或者gbk，防止中文亂碼。

2，為工程添加附加依賴項(xiàng)wsock32.lib和libmysql.lib，一種方式是工程--屬性--鏈接器--輸入--附加依賴項(xiàng)，另一種是在程序開頭用#pragma comment(lib,"xxx.lib")

3，為程序添加頭文件"mysql.h"和WinSock.h

二、示例代碼

#include

#include //一定要包含這個(gè)，或者winsock2.h

#include "include/mysql.h" //引入mysql頭文件(一種方式是在vc目錄里面設(shè)置，一種是文件夾拷到工程目錄，然后這樣包含)

#include

//包含附加依賴項(xiàng)，也可以在工程--屬性里面設(shè)置

#pragma comment(lib,"wsock32.lib")

#pragma comment(lib,"libmysql.lib")

MYSQL mysql; //mysql連接

MYSQL_FIELD *fd; //字段列數(shù)組

char field[32][32]; //存字段名二維數(shù)組

MYSQL_RES *res; //這個(gè)結(jié)構(gòu)代表返回行的一個(gè)查詢結(jié)果集

MYSQL_ROW column; //一個(gè)行數(shù)據(jù)的類型安全(type-safe)的表示，表示數(shù)據(jù)行的列

char query[150]; //查詢語句

bool ConnectDatabase(); //函數(shù)聲明

void FreeConnect();

bool QueryDatabase1(); //查詢1

bool QueryDatabase2(); //查詢2

bool InsertData();

bool ModifyData();

bool DeleteData();

int main(int argc,char **argv)

{

ConnectDatabase();

QueryDatabase1();

InsertData();

QueryDatabase2();

ModifyData();

QueryDatabase2();

DeleteData();

QueryDatabase2();

FreeConnect();

system("pause");

return 0;

}

//連接數(shù)據(jù)庫

bool ConnectDatabase()

{

//初始化mysql

mysql_init(&mysql); //連接mysql，數(shù)據(jù)庫

//返回false則連接失敗，返回true則連接成功

if (!(mysql_real_connect(&mysql,"localhost", "root", "", "test",0,NULL,0))) //中間分別是主機(jī)，用戶名，密碼，數(shù)據(jù)庫名，端口號(可以寫默認(rèn)0或者3306等)，可以先寫成參數(shù)再傳進(jìn)去

{

printf( "Error connecting to database:%s\n",mysql_error(&mysql));

return false;

}

else

{

printf("Connected...\n");

return true;

}

}

//釋放資源

void FreeConnect()

{

//釋放資源

mysql_free_result(res);

mysql_close(&mysql);

}

/***************************數(shù)據(jù)庫操作***********************************/

//其實(shí)所有的數(shù)據(jù)庫操作都是先寫個(gè)sql語句，然后用mysql_query(&mysql,query)來完成，包括創(chuàng)建數(shù)據(jù)庫或表，增刪改查

//查詢數(shù)據(jù)

bool QueryDatabase1()

{

sprintf(query, "select * from user"); //執(zhí)行查詢語句，這里是查詢所有，user是表名，不用加引號，用strcpy也可以

mysql_query(&mysql,"set names gbk"); //設(shè)置編碼格式(SET NAMES GBK也行)，否則cmd下中文亂碼

//返回0 查詢成功，返回1查詢失敗

if(mysql_query(&mysql, query)) //執(zhí)行SQL語句

{

printf("Query failed (%s)\n",mysql_error(&mysql));

return false;

}

else

{

printf("query success\n");

}

//獲取結(jié)果集

if (!(res=mysql_store_result(&mysql))) //獲得sql語句結(jié)束后返回的結(jié)果集

{

printf("Couldn't get result from %s\n", mysql_error(&mysql));

return false;

}

//打印數(shù)據(jù)行數(shù)

printf("number of dataline returned: %d\n",mysql_affected_rows(&mysql));

//獲取字段的信息

char *str_field[32]; //定義一個(gè)字符串?dāng)?shù)組存儲(chǔ)字段信息

for(int i=0;i<4;i++) //在已知字段數(shù)量的情況下獲取字段名

{

str_field[i]=mysql_fetch_field(res)->name;

}

for(int i=0;i<4;i++) //打印字段

printf("%10s\t",str_field[i]);

printf("\n");

//打印獲取的數(shù)據(jù)

while (column = mysql_fetch_row(res)) //在已知字段數(shù)量情況下，獲取并打印下一行

{

printf("%10s\t%10s\t%10s\t%10s\n", column[0], column[1], column[2],column[3]); //column是列數(shù)組

}

return true;

}

bool QueryDatabase2()

{

mysql_query(&mysql,"set names gbk");

//返回0 查詢成功，返回1查詢失敗

if(mysql_query(&mysql, "select * from user")) //執(zhí)行SQL語句

{

printf("Query failed (%s)\n",mysql_error(&mysql));

return false;

}

else

{

printf("query success\n");

}

res=mysql_store_result(&mysql);

//打印數(shù)據(jù)行數(shù)

printf("number of dataline returned: %d\n",mysql_affected_rows(&mysql));

for(int i=0;fd=mysql_fetch_field(res);i++) //獲取字段名

strcpy(field[i],fd->name);

int j=mysql_num_fields(res); // 獲取列數(shù)

for(int i=0;i

printf("%10s\t",field[i]);

printf("\n");

while(column=mysql_fetch_row(res))

{

for(int i=0;i

printf("%10s\t",column[i]);

printf("\n");

}

return true;

}

//插入數(shù)據(jù)

bool InsertData()

{

sprintf(query, "insert into user values (NULL, 'Lilei', 'wyt2588zs','lilei23@sina.cn');"); //可以想辦法實(shí)現(xiàn)手動(dòng)在控制臺(tái)手動(dòng)輸入指令

if(mysql_query(&mysql, query)) //執(zhí)行SQL語句

{

printf("Query failed (%s)\n",mysql_error(&mysql));

return false;

}

else

{

printf("Insert success\n");

return true;

}

}

//修改數(shù)據(jù)

bool ModifyData()

{

sprintf(query, "update user set email='lilei325@163.com' where name='Lilei'");

if(mysql_query(&mysql, query)) //執(zhí)行SQL語句

{

printf("Query failed (%s)\n",mysql_error(&mysql));

return false;

}

else

{

printf("Insert success\n");

return true;

}

}

//刪除數(shù)據(jù)

bool DeleteData()

{

/*sprintf(query, "delete from user where id=6");*/

char query[100];

printf("please input the sql:\n");

gets(query); //這里手動(dòng)輸入sql語句

if(mysql_query(&mysql, query)) //執(zhí)行SQL語句

{

printf("Query failed (%s)\n",mysql_error(&mysql));

return false;

}

else

{

printf("Insert success\n");

return true;

}

}

運(yùn)行結(jié)果：

三、mysql API接口匯總

mysql_affected_rows() 返回被最新的UPDATE, DELETE或INSERT查詢影響的行數(shù)。

mysql_close() 關(guān)閉一個(gè)服務(wù)器連接。

mysql_connect() 連接一個(gè)MySQL服務(wù)器。該函數(shù)不推薦；使用mysql_real_connect()代替。

mysql_change_user() 改變在一個(gè)打開的連接上的用戶和數(shù)據(jù)庫。

mysql_create_db() 創(chuàng)建一個(gè)數(shù)據(jù)庫。該函數(shù)不推薦；而使用SQL命令CREATE DATABASE。

mysql_data_seek() 在一個(gè)查詢結(jié)果集合中搜尋一任意行。

mysql_debug() 用給定字符串做一個(gè)DBUG_PUSH。

mysql_drop_db() 拋棄一個(gè)數(shù)據(jù)庫。該函數(shù)不推薦；而使用SQL命令DROP DATABASE。

mysql_dump_debug_info() 讓服務(wù)器將調(diào)試信息寫入日志文件。

mysql_eof() 確定是否已經(jīng)讀到一個(gè)結(jié)果集合的最后一行。這功能被反對; mysql_errno()或mysql_error()可以相反被使用。

mysql_errno() 返回最近被調(diào)用的MySQL函數(shù)的出錯(cuò)編號。

mysql_error() 返回最近被調(diào)用的MySQL函數(shù)的出錯(cuò)消息。

mysql_escape_string() 用在SQL語句中的字符串的轉(zhuǎn)義特殊字符。

mysql_fetch_field() 返回下一個(gè)表字段的類型。

mysql_fetch_field_direct () 返回一個(gè)表字段的類型，給出一個(gè)字段編號。

mysql_fetch_fields() 返回一個(gè)所有字段結(jié)構(gòu)的數(shù)組。

mysql_fetch_lengths() 返回當(dāng)前行中所有列的長度。

mysql_fetch_row() 從結(jié)果集合中取得下一行。

mysql_field_seek() 把列光標(biāo)放在一個(gè)指定的列上。

mysql_field_count() 返回最近查詢的結(jié)果列的數(shù)量。

mysql_field_tell() 返回用于最后一個(gè)mysql_fetch_field()的字段光標(biāo)的位置。

mysql_free_result() 釋放一個(gè)結(jié)果集合使用的內(nèi)存。

mysql_get_client_info() 返回客戶版本信息。

mysql_get_host_info() 返回一個(gè)描述連接的字符串。

mysql_get_proto_info() 返回連接使用的協(xié)議版本。

mysql_get_server_info() 返回服務(wù)器版本號。

mysql_info() 返回關(guān)于最近執(zhí)行得查詢的信息。

mysql_init() 獲得或初始化一個(gè)MYSQL結(jié)構(gòu)。

mysql_insert_id() 返回有前一個(gè)查詢?yōu)橐粋€(gè)AUTO_INCREMENT列生成的ID。

mysql_kill() 殺死一個(gè)給定的線程。

mysql_list_dbs() 返回匹配一個(gè)簡單的正則表達(dá)式的數(shù)據(jù)庫名。

mysql_list_fields() 返回匹配一個(gè)簡單的正則表達(dá)式的列名。

mysql_list_processes() 返回當(dāng)前服務(wù)器線程的一張表。

mysql_list_tables() 返回匹配一個(gè)簡單的正則表達(dá)式的表名。

mysql_num_fields() 返回一個(gè)結(jié)果集合重的列的數(shù)量。

mysql_num_rows() 返回一個(gè)結(jié)果集合中的行的數(shù)量。

mysql_options() 設(shè)置對mysql_connect()的連接選項(xiàng)。

mysql_ping() 檢查對服務(wù)器的連接是否正在工作，必要時(shí)重新連接。

mysql_query() 執(zhí)行指定為一個(gè)空結(jié)尾的字符串的SQL查詢。

mysql_real_connect() 連接一個(gè)MySQL服務(wù)器。

mysql_real_query() 執(zhí)行指定為帶計(jì)數(shù)的字符串的SQL查詢。

mysql_reload() 告訴服務(wù)器重裝授權(quán)表。

mysql_row_seek() 搜索在結(jié)果集合中的行，使用從mysql_row_tell()返回的值。

mysql_row_tell() 返回行光標(biāo)位置。

mysql_select_db() 連接一個(gè)數(shù)據(jù)庫。

mysql_shutdown() 關(guān)掉數(shù)據(jù)庫服務(wù)器。

mysql_stat() 返回作為字符串的服務(wù)器狀態(tài)。

mysql_store_result() 檢索一個(gè)完整的結(jié)果集合給客戶。

mysql_thread_id() 返回當(dāng)前線程的ID。

mysql_use_result() 初始化一個(gè)一行一行地結(jié)果集合的檢索。

我自己用c語言寫的

#include

#include

int main(int argc, char *srgv[])

{

MYSQL *conn_ptr;

MYSQL_RES *res; //這個(gè)結(jié)構(gòu)代表返回行的一個(gè)查詢結(jié)果集

MYSQL_ROW column; //一個(gè)行數(shù)據(jù)的類型安全(type-safe)的表示，表示數(shù)據(jù)行的列

conn_ptr = mysql_init(NULL);

if (NULL == conn_ptr)

{

printf("mysql_init failed\n");

}

if (!(mysql_real_connect(conn_ptr, "localhost", "root", "root", "a", 0, NULL, 0)))

{

printf("Error connecting to database:%s\n", mysql_error(conn_ptr));

//return 0;

}

else

{

printf("Connected...\n");

//return 1;

}

mysql_query(conn_ptr, "set names gbk");

if (mysql_query(conn_ptr, "select * from t2")) //執(zhí)行SQL語句

{

printf("Query failed (%s)\n", mysql_error(conn_ptr));

}

else

{

printf("query success\n");

}

//獲取結(jié)果集

if (!(res = mysql_store_result(conn_ptr))) //獲得sql語句結(jié)束后返回的結(jié)果集

{

printf("Couldn't get result from %s\n", mysql_error(conn_ptr));

//return false;

}

//打印數(shù)據(jù)行數(shù)

printf("number of dataline returned: %d\n", mysql_affected_rows(conn_ptr));

printf("\tid\tname\t\n"); //column是列數(shù)組

//打印獲取的數(shù)據(jù)

while (column = mysql_fetch_row(res)) //在已知字段數(shù)量情況下，獲取并打印下一行

{

printf("%10s\t%10s\t\n", column[0], column[1]); //column是列數(shù)組

}

_getch();

return 0;

}

總結(jié)

以上是生活随笔為你收集整理的c 连接mysql怎么增删改_C++ API方式连接mysql数据库实现增删改查的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。