2. 程式人生 > >c++操作數據庫

c++操作數據庫

阿新 • • 發佈：2018-11-26
read cti ongl ins 一個數 col ble enum end

  1. 使用mysql_init()初始化連接
  2. 使用mysql_real_connect()建立一個到mysql數據庫的連接
  3. 使用mysql_query()執行查詢語句
  4. result = mysql_store_result(mysql)獲取結果集
  5. mysql_num_fields(result)獲取查詢的列數，mysql_num_rows(result)獲取結果集的行數
  6. 通過mysql_fetch_row(result)不斷獲取下一行，然後循環輸出
  7. 釋放結果集所占內存mysql_free_result(result)
  8. 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++操作數據庫

相關推薦

c++操作數據庫

read cti ongl ins 一個數 col ble enum end 使用mysql_init()初始化連接 使用mysql_real_connect()建立一個到mysql數據庫的連接 使用mysql_query()執行查詢語句 result = mysql_s

C#中操作數據庫技術之ExecuteNonQuery用法

pen cte assign == ted for 返回 簡單的 splay 最近在補基礎知識，剛好補到C#中對數據庫操作的一些技術，今天學習了ExecuteNonQuery的東西，看自己項目維護項目的代碼和網上資料查詢，基本上搞懂了ExecuteNonQuery的用法，小

Jmter操作數據庫

res port database allow pac jar back add jdb 1、導入jdbc的jar包，因為jmeter本身不能直接連接mysql，所以需要導入第三方的jar包，來連接mysql，如下操作： 2、創建數據庫連接如下： 3、配置my

Android:日常學習筆記(10)———使用LitePal操作數據庫

分享 數據 turn find netstat price 彈出 category 模式 Android:日常學習筆記(10)———使用LitePal操作數據庫 引入LitePal 什麽是LitePal 　　LitePal是一款開源的Android數據庫框架，采用了對象關系

jdbc操作數據庫

clas www sql ear state man tostring 方便 html JDBC： 幹什麽？ 可以是程序和數據庫之間建立相應的關系 並且可以操作數據庫，方便程序獲取數據和操作數據 如何操

python操作數據庫-數據表

title 獲取 arch python操作 -- pymysql exe span 轉義 數據表： 數據類型： 幫助的三種形式： 在cmd中輸入： help 要幫助的主題詞，或 ? 要幫助的主題詞 或 \h 要幫助的主題詞 。 數據表的創建：

Servlet中操作數據庫

enter font emp nbsp app ima finally root oct 以下內容引用自http://wiki.jikexueyuan.com/project/servlet/database-access.html： 前提先新建數據庫及插入模擬數據：

python-操作數據庫

span arch logs all 127.0.0.1 ace delet 自增 pan python DB-API介紹 1.python標準數據庫接口為 python DB-API,python DB-API為開發人員提供了數據庫應用標稱接口 2.python數據庫接口

C語言數據庫數據類型

適配器 偏移 生成 包含 建數據庫 decimal create prim 包括 ??數據類型是一種屬性，用於指定對象可保存的數據的類型，SQL Server中支持多種數據類型，包括字符類型、數值類型以及日期類型等。數據類型相當於一個容器，容器的大小決定了裝的東西的多少，將

python操作數據庫（MySQL、redis）

absolut lec pen 鏈接 hone key imp iam sql 1、Python3操作MySQL數據庫需要安裝一個第三方模塊(pymysql)：pip install pymysql；操作redis需要安裝redis模塊(redis)：pip install

python操作數據庫

python3 部分 系統框架 all 方法 pip mysql數據庫 app class 一.python操作數據庫 這裏主要介紹python3的一些操作方法.以下介紹python操作兩種數據庫,兩種數據庫部分好壞,只是看當時哪一種更適合所開發的系統框架. (一)pyt

java操作數據庫定時備份與還原

名稱 數據 rri att trac catch form number ride mysql每天23:00自動備份 public class DatabaseBackup { /** * * @param dbdir mysql數據

Asp.net連接數據庫及操作數據庫--入門

pen close 綁定 oid void area set 公共類 連接數據庫 1.創建公共類DB--4個方法。GetCon()//連接數據庫，sqlEx//執行數據庫操作， reDt//返回數據表， reDr//返回SqlDataReader對象 dr ///&l

JDBC操作數據庫，比如修改電商數據庫中的分類的id，讓各商品隨機

url spa creates 需要 stat 句柄 獲取 amp statement 1 package CRM; 2 3 import java.sql.Connection; 4 import java.sql.DriverManager; 5 impo

mysqli操作數據庫

php mysqli 數據庫一． 建立和斷開連接與MySQL數據庫交互時，首先要建立連接，最後要斷開連接，這包括與服務器連接並選擇一個數據庫，以及最後關閉連接。與mysqli幾乎所有的特性一樣，這一點可以使用面向對象的方法來完成，也可以采用過程化的方式完成。1.創建一個mysqli的對象$_mysqli =

JDBC操作數據庫之連接數據庫

log color his null creat pda url root 數據庫連接字符串 通過JDBC向數據庫中添加數據的時候，使用insert語句實現數據的插入，再SQL語句中的參數可以用占位符“？”來替代，然後通過PreparedStatement對象或者Sta

JDBC操作數據庫之查詢數據

arr 移動 null pattern || tle back pub long 以數據庫中查找圖書信息，並將信息顯示在jsp頁面當中為例，下面貼上代碼片段： （1）在index.jsp頁面代碼body中只要添加如下一段代碼： <a href="FindServlet

JDBC操作數據庫之修改數據

order 開發 操作 名稱 ret adding inpu 過程 log 使用JDBC修改數據庫中的數據，起操作方法是和添加數據差不多的，只不過在修改數據的時候還要用到UPDATE語句來實現的，例如：把圖書信息id為1的圖書數量改為100，其sql語句是：update b

JDBC操作數據庫之批處理

解決方案 print 數據庫服務器 密碼 red rep 參數 connect jdb JDBC開發中，操作數據庫需要和數據庫建立連接，然後將要執行的SQL語句發送到數據庫服務器，最後關閉數據庫連接，都是按照這樣的操做的，如果按照此流程要執行多條SQL語句，那麽就要建立多個

Python操作數據庫（mysql redis）

tex 行數 元組 cursor nosql sql數據庫 字段 函數 mysql數據庫 一、python操作mysql數據庫： 數據庫信息：(例如211.149.218.16 szz 123456) 操作mysql用pymysql模塊