标签：insert char endTime tables int create Util mysql include

#ifndef Util_H
#define Util_H
#include <functional>
#include <iostream>
#include <mysql/mysql.h>
#include <sstream>
#include <string.h>
#include <uuid/uuid.h> 
#include <vector>
#include "Model/Geeks.h"
#include "Model/Parent.h"
#include "Model/BookStruct.cpp"


char* Util::uuidValue=(char*)malloc(40);
char* Util::dtValue=(char*)malloc(20);

char *Util::getUuid()
{
    uuid_t newUUID;
    uuid_generate(newUUID);
    uuid_unparse(newUUID, uuidValue);
    return uuidValue;
}

char *Util::getTimeNow()
{
    time_t rawTime=time(NULL);
    struct tm tmInfo=*localtime(&rawTime);
    strftime(dtValue,20,"%y%m%d%H%M%S",&tmInfo);
    return dtValue;
}

void Util::insertInBulkViaMySqlClient6(int loops)
{
    try
    {
        MYSQL *conn,mysql;
        mysql_init(&mysql);
        int queryState;

        conn=mysql_real_connect(&mysql,"localhost","root","Root0001!","db",0,0,0);
        if(conn==NULL)
        {
            cout<<mysql_error(&mysql)<<endl;
            return;
        }
        stringstream ss;
        int interval=1000000;
        string sqlStr;
        chrono::time_point<chrono::system_clock> startTime;
        chrono::time_point<chrono::system_clock> endTime;
        long double num=0;
        for(int i=1;i<=loops;i++)
        {
            startTime=chrono::system_clock::now();
            ss=stringstream();
            ss<<"create table mt"<<i<<"(BookIndex int not null auto_increment,BookId bigint not null default 0,BookName varchar(50) not null default '',BookTitle varchar(50) not null default '',primary key(BookIndex));";
            queryState=mysql_query(conn,ss.str().c_str());
            if(queryState!=0)
            {
                cout<<"Create table mt"<<i<<" failed!"<<endl;
                return;
            }            
            cout<<"Create table mt"<<i<<" successfully!"<<endl;

            ss=stringstream();
            ss<<"Insert into mt"<<i<<" (BookId,BookName,BookTitle) values ";
            for(int j=1;j<=interval;j++)
            {
                ++num;
                ss<<"("<<(i-1)*interval+j<<",'"<<getUuid()<<"','"<<getUuid()<<"'),";
            }
            sqlStr=ss.str();
            int lastCommaIndex=sqlStr.find_last_of(",");
            sqlStr=sqlStr.erase(lastCommaIndex,1);
            queryState=mysql_query(conn,sqlStr.c_str());
            if(queryState!=0)
            {
                cout<<"Insert into table mt"<<i<<" failed!"<<endl;
                return;
            }
            endTime=chrono::system_clock::now();
            cout<<"Now is "<<getTimeNow()<<",num="<<num<<",create and insert into table mt"<<i<<" successfully!,time cost:" 
            <<chrono::duration_cast<chrono::seconds>(endTime-startTime).count()<<" seconds,"
            <<chrono::duration_cast<chrono::milliseconds>(endTime-startTime).count()<<" milli,"
            <<chrono::duration_cast<chrono::microseconds>(endTime-startTime).count()<<" micro,"
            <<chrono::duration_cast<chrono::nanoseconds>(endTime-startTime).count()<<" nanos!!!"<<endl<<endl;
        }
        mysql_close(conn);
        ss=stringstream();
        cout<<"Finished in void Util::insertInBulkViaMySqlClient6(int loops) and now is "<<getTimeNow()<<endl;
    }
    catch(const std::exception& e)
    {
        std::cerr << e.what() << '\n';
    }
    
}

void mysqlInsertInBulk4(int loops);

int main(int args,char **argv)
{
    mysqlInsertInBulk4(atoi(argv[1]));
}

void mysqlInsertInBulk4(int loops)
{
    Util ul;
    ul.insertInBulkViaMySqlClient6(loops);
}

Compile

g++ -g -std=c++2a -I. *.cpp ./Model/*.cpp -o h1 -luuid -lmysqlclient;

Run

time ./h1 200

//Show created tables in mysql

select group_concat(table_name) from information_schema.tables where table_schema='db' and table_name regexp '[0-9]';

标签：insert,char,endTime,tables,int,create,Util,mysql,include
来源： https://www.cnblogs.com/Fred1987/p/16296053.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。