c++操作資料庫

阿新 • • 發佈：2018-11-25

使用mysql_init()初始化連線
使用mysql_real_connect()建立一個到mysql資料庫的連線
使用mysql_query()執行查詢語句
result = mysql_store_result(mysql)獲取結果集
mysql_num_fields(result)獲取查詢的列數，mysql_num_rows(result)獲取結果集的行數
通過mysql_fetch_row(result)不斷獲取下一行，然後迴圈輸出
釋放結果集所佔記憶體mysql_free_result(result)
mysql_close(conn)關閉連線

以下程式碼塊是用來連線資料庫的通訊過程，要連線MYSQL，必須建立MYSQL例項，通過mysql_init初始化方能開始進行連線.

typedef struct st_mysql {
 NET           net;            /* Communication parameters */
 gptr          connector_fd;   /* ConnectorFd for SSL */
 char          *host,*user,*passwd,*unix_socket,
                *server_version,*host_info,*info,*db;
 unsigned  
int port,client_flag,server_capabilities;
 unsigned int protocol_version;
 unsigned int field_count;
 unsigned int server_status;
 unsigned long thread_id;      /* Id for connection in server */
 my_ulonglong affected_rows;
 my_ulonglong insert_id;       /* id if insert on table with NEXTNR */
 my_ulonglong extra_info;               
/* Used by mysqlshow */
 unsigned long packet_length;
 enum mysql_status status;
 MYSQL_FIELD   *fields;
 MEM_ROOT      field_alloc;
 my_bool       free_me;        /* If free in mysql_close */
 my_bool       reconnect;      /* set to 1 if automatic reconnect */
 struct st_mysql_options options;
 char          scramble_buff[9];
 struct charset_info_st *charset;
 unsigned int server_language;
} MYSQL;

這個結構代表返回行的一個查詢的(SELECT, SHOW, DESCRIBE, EXPLAIN)的結果。返回的資料稱為“資料集”，在C的API裡對應的就是MYSQL_RES了，從資料庫讀取資料，最後就是從MYSQL_RES中讀取資料。

typedef struct st_mysql_res {
 my_ulonglong row_count;
 unsigned int field_count, current_field;
 MYSQL_FIELD   *fields;
 MYSQL_DATA    *data;
 MYSQL_ROWS    *data_cursor;
 MEM_ROOT      field_alloc;
 MYSQL_ROW     row;            /* If unbuffered read */
 MYSQL_ROW     current_row;    /* buffer to current row */
 unsigned long *lengths;       /* column lengths of current row */
 MYSQL         *handle;        /* for unbuffered reads */
 my_bool       eof;            /* Used my mysql_fetch_row */
} MYSQL_RES;

mysql_init

#include <mysql/mysql.h>
MYSQL *mysql_init(MYSQL *mysql)

功能：獲得或初始化一個MYSQL結構

函式返回值：一個被始化的MYSQL*控制代碼

備註：在記憶體不足的情況下，返回NULL

mysql_close(MYSQL *mysql)

 #include <mysql/mysql.h>
void mysql_close(MYSQL *mysql);

函式功能：關閉一個伺服器連線，並釋放與連線相關的記憶體

函式傳入值： MYSQL:型別的指標

函式返回值：無

mysql_connect

 #include <mysql/mysql.h>
MYSQL * mysql_connect(MYSQL *mysql,const char *host,const char *user,const char *passwd);

函式功能：連線一個MySQL伺服器

函式傳入值： mysql表示一個現存mysql結構的地址 host表示MYSQL伺服器的主機名或IP user表示登入的使用者名稱 passwd表示登入的密碼

函式返回值：如果連線成功，一個MYSQL *連線控制代碼：如果連線失敗，NULL

備註：該函式不推薦，使用mysql_real_connect()代替

mysql_real_connect

#include <mysql/mysql.h> 
MYSQL  *mysql_real_connect(MYSQL *mysql,const char *host,const char *user,const  char *passwd,const char *db,unsigned int port,const char  *unix_socket,unsigned int client_flag);

函式傳入值： mysql表示一個現存mysql結構的地址 host表示MYSQL伺服器的主機名或IP user表示登入的使用者名稱 passwd表示登入的密碼 db表示要連線的資料庫 port表示MySQL伺服器的TCP/IP埠 unix_socket表示連線型別 client_flag表示MySQL執行ODBC資料庫的標記

函式返回值：如果連線成功，一個MYSQL*連線控制代碼：

如果連線失敗，NULL

mysql_affected_rows

函式功能：返回最新的UPDATE，DELETE或INSERT查詢影響的行數

函式傳入值： MYSQL:型別指標

函式返回值：大於零的一個整數表示受到影響或檢索出來的行數。零表示沒有區配查序中WHERE子句的記錄或目前還沒有查詢被執行;-1表示查詢返回一個錯誤，或對於一個SELECT查詢

mysql_query

 #include <mysql/mysql.h>
int mysql_query(MYSQL *mysql,const char *query);

函式功能：對指定的連線執行查詢

函式傳入值： query表示執行的SQL語句

函式返回值：如果查詢成功，為零，出錯為非零

相關函式： mysql_real_query

mysql_use_result

 #include <mysql/mysql.h>
MYSQL_RES *mysql_use_result(MYSQL *mysql);

函式功能：為無緩衝的結果集獲得結果識別符號

函式傳入值： MYSQL:型別的指標

函式返回值：一個MYSQL_RES結果結構，如果發生一個錯誤發NULL

詳細參考https://www.cnblogs.com/tianzeng/p/10016943.html

mysql_fetch_row

#incluee <mysql/mysql.h>
mysql_fetch_row(MYSQL_RES *result);

檢索一個結果集合的下一行 MYSQL_ROW

MYSQL_RES:結構的指標下一行的一個MYSQL_ROW結構。如果沒有更多的行可檢索或如果出現一個錯誤，NULL

mysql_num_fields

#include <mysql/mysql.h>
unsigned int mysql_num_fields(MYSQL_RES *res);

返回指定結果集中列的數量MYSQL_RES 結構的指標

結果集合中欄位數量的一個無符號整數

mysql_create_db

#include <mysql/mysql.h>
int mysql_create_db(MYSQL *mysql,const char *db);

建立一個數據庫

MYSQL：型別的指標 db:要建立的資料庫名如果資料庫成功地被建立，返回零，如果發生錯誤，為非零。

mysql_select_db

#include <mysql/mysql.h>
int mysql_select_db(MYSQL *mysql,const char *db);

選擇一個數據庫

db:要建立的資料庫名如果資料庫成功地被建立，返回零，如果發生錯誤，為非零。

/*************************************************************************
    > File Name: db.h
    > Author: Chen Tianzeng
    > Mail: [email protected] 
    > Created Time: 2018年11月25日 星期日 17時21分37秒
 ************************************************************************/

#ifndef DB_H
#define DB_H
#include <iostream>
#include <mysql/mysql.h>
#include <string>
using namespace std;

class Db
{
    private:
        MYSQL *con;
        MYSQL_RES *res;
        MYSQL_ROW row;

    public:
        Db();
        ~Db();
        bool init_db(string host,string user,string pwd,string db_name);
        bool exec(string sql);
};

#endif

/*************************************************************************
    > File Name: db.cpp
    > Author: Chen Tianzeng
    > Mail: [email protected] 
    > Created Time: 2018年11月25日 星期日 17時25分04秒
 ************************************************************************/

#include "db.h"
using namespace std;

Db::Db()
{
    con=mysql_init(NULL);//初始化連結變數
    if(con==NULL)
    {
        cerr<<"error: "<<mysql_error(con)<<endl;
        exit(1);
    }
}

Db::~Db()
{
    if(con)
        mysql_close(con);
}

bool Db::init_db(string host,string user,string pwd,string db_name)
{
    //用mysql_real_connect建立一個連線
    con=mysql_real_connect(con,host.c_str(),user.c_str(),pwd.c_str(),
                                db_name.c_str(),0,NULL,0);
    if(con==NULL)
    {
        cerr<<"error: "<<mysql_error(con)<<endl;
        exit(1);
    }
    return true;
}

bool Db::exec(string sql)
{
    //執行sql查詢語句,成功返回0，失敗返回非0
    if(mysql_query(con,sql.c_str()))
    {
        cerr<<"query error: "<<mysql_error(con)<<endl;
        exit(1);
    }
    else
    {
        //獲取查詢的結果
        res=mysql_store_result(con);
        if(res)
        {
            //返回查詢的列數
            for(int i=0;i<mysql_num_rows(res);++i)
            {
                row=mysql_fetch_row(res);
                if(row<0)
                    break;

                //結果集中的欄位數
                for(int j=0;j<mysql_num_fields(res);++j)
                    cout<<row[j]<<" ";
                cout<<endl;
            }
        }
        else//res==NULL
        {
            if(mysql_field_count(con)==0)//返回insert update delete 等影響的列數
                int num_rows=mysql_affected_rows(con);
            else
            {
                cout<<"get result error: "<<mysql_error(con)<<endl;
                return false;
            }
        }
    }
    //釋放結果集
    mysql_free_result(res);
    return true;
}

/*************************************************************************
    > File Name: main.cpp
    > Author: Chen Tianzeng
    > Mail: [email protected] 
    > Created Time: 2018年11月25日 星期日 17時39分06秒
 ************************************************************************/

#include "db.h"
using namespace std;

int main()
{
    Db db;
    db.init_db("localhost","root","root","stu");
    db.exec("select * from stu_info");
    //db.exec("insert into stu_info values('000002','hualian','21','1005',100)");
    return 0;
}

Makefile

CC=g++
OBJS=main.o db.o
EXEC=main
CPPFLAGS=-std=c++11
LIB=-L/usr/lib64 -lmysqlclient
.PHONY:clean

$(EXEC):$(OBJS)
    $(CC) $(OBJS) -o $(EXEC) $(CPPFLAFS) $(LIB)

clean:
    rm -rf $(OBJS)
    rm -rf $(EXEC)

MySQL官方參考文件 https://dev.mysql.com/doc/refman/8.0/en/c-api-functions.html

c++操作資料庫

mysql_init

mysql_close(MYSQL *mysql)

mysql_connect

mysql_real_connect

mysql_affected_rows

mysql_query

mysql_use_result

mysql_fetch_row

mysql_num_fields

mysql_create_db

mysql_select_db

c++操作資料庫

關於用C#操作資料庫中的Image資料

C#操作資料庫的常用公共方法！

簡單的 C++ 操作資料庫類

C# SqlCommand 資料庫連線操作

C#操作SQLite資料庫時出錯總結--錯誤：“Insufficient parameters supplied to the command”

C#對資料庫的操作（查詢，刪除，更新）

C#操作MongoDB資料庫方法

C#操作MongoDB資料庫並獲取資料方法

C++使用MySql++操作資料庫例項

PC軟體開發技術之三：C#操作SQLite資料庫

c#對資料庫的操作程式碼（MySql.Data.dll包）

c#操作DBF資料庫檔案

c# 對資料庫的操作

C# Oracle資料庫連線及操作

C#連線Oracle資料庫通過儲存過程操作資料庫

C# Oracle資料庫操作類

C/C++操作MySQL資料庫——增、刪、改、查

[C++]MYSQL 資料庫操作封裝及連線池實現

C# 操作PostgreSQL 資料庫

c++操作資料庫

mysql_init

mysql_close(MYSQL *mysql)

mysql_connect

mysql_real_connect

mysql_affected_rows

mysql_query

mysql_use_result

mysql_fetch_row

mysql_num_fields

mysql_create_db

mysql_select_db

相關推薦