c/c++批量向mysql插入数据

 

先给个MYSQL对于C的API

具体代码，改为手动提交，每次5W数据

 //mysql所需的头文件和库文件  

#include "winsock.h" 

#include <Windows.h>
#include <stdio.h>
#include <stdlib.h>

#include "mysql.h"
#include<fstream>
#include <string>
#include <iostream>
using namespace std;

int main()
{
    //配置文件
    ifstream configFin("config.txt");

    string processFile;//要处理的文件名字
    string dbhost;//数据库主机
    string dbuser;//数据库用户名
    string dbpwd;//数据库密码
    string dbname;//数据库名字
    string tmp;
    configFin>>tmp>>processFile>>tmp>>dbhost>>tmp>>dbuser>>tmp>>dbpwd>>tmp>>dbname;

    
    unsigned int port = 3306;           //server port        
    MYSQL myCont;
    mysql_init(&myCont);
    string uid, friendid;
    
    ifstream fin(processFile.c_str());
    int i=0;
    int eachCount = 0;
    string sql;
    while(!fin.eof()){
        if(mysql_real_connect(&myCont,dbhost.c_str(),dbuser.c_str(),dbpwd.c_str(),dbname.c_str(),port,NULL,CLIENT_MULTI_STATEMENTS)){
            mysql_autocommit(&myCont,0);

            mysql_query(&myCont, "SET NAMES utf8");
            for(eachCount=0; eachCount<50000; ++eachCount){
                if(fin>>uid>>friendid){
                    sql = "insert into friendlist values('"+uid+"','"+friendid+"');";
                    mysql_query(&myCont, sql.c_str());
                }
            }
            cout<<". ";
            mysql_commit(&myCont);
            mysql_close(&myCont);//断开连接
        }else{
            cout<<"connect failed!"<<endl;
        }
        
    }
    fin.close();
        

    system("pause");
    return 0;
}

大致说一下C链接MYSQL的方法：

1、去官方下载mysql和c的connector

2、拷贝里面的lib目录下的dll和lib文件到当前目录下

3、设置当前项目的头文件位下载的目录下的inlcude

4、设置一个lib库（在项目设置里），设置第2步的文件名

5、用上述程序就可以连接（数据库地址之类的，自己改掉） 
----------------------------------------

insert插入多条数据有二种方法一种是写多条insert 语句用";"号分割每条sql,一种是insert本身的多个value

1,写多条insert用";"分割
这个很简单,;号是mysql执行sql的结束符,写多个insert用;号割就是让mysql执行多次而已.比如:
insert into table (field1,field2,field3) value ('a',"b","c");
insert into table (field1,field2,field3) value ('a',"b","c");
insert into table (field1,field2,field3) value ('a',"b","c");
insert into table (field1,field2,field3) value ('a',"b","c");
insert into table (field1,field2,field3) value ('a',"b","c");

2,在insert中写多个value
INSERT INTO table (field1,field2,field3) VALUES ('a',"b","c"), ('a',"b","c"),('a',"b","c");