标签：std Util read res C++ char sql table include

//Utill.h
#ifndef Util_H
#define Util_H

#include <chrono>
#include <ctime>
#include <fstream> 
#include <iostream>
#include "mysql_connection.h"
#include <cppconn/driver.h>
#include <cppconn/exception.h>
#include <cppconn/resultset.h>
#include <cppconn/statement.h>
#include <cppconn/prepared_statement.h>
#include <sstream>
#include <stdlib.h>
#include <thread>
#include <unistd.h>
#include <uuid/uuid.h>
#include <vector>

using namespace std;

class Util
{
public:
    static char *uuidValue;
    static char *dtValue;
    char *getTime();
    char *getUuid(); 
    void readSQL5();
};
#endif




//Util.cpp
#include "Model/Util.h"

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

void Util::readSQL5()
{
    try
    {
        sql::Driver *driver;
        sql::Connection *conn;
        sql::Statement *stmt;
        sql::PreparedStatement *pstmt;
        sql::ResultSet *res;
        sql::PreparedStatement *tablePstmt;
        sql::ResultSet *tableRes;

        driver = get_driver_instance();
        conn = driver->connect("tcp://127.0.0.1:3306", "root", "Root0001!");
        conn->setSchema("db");

        string selectTable = "select table_name from information_schema.tables where table_schema='db'";
        pstmt = conn->prepareStatement(selectTable);
        res = pstmt->executeQuery();

        vector<string> tableVec;
        while (res->next())
        {
            tableVec.push_back(res->getString(1));
        }

        vector<string>::iterator itr = tableVec.begin();
        cout << "Table:";
        while (itr != tableVec.end())
        {
            cout << *itr << "\t";
            itr++;
        }
        cout << endl << endl;

        uint64_t num = 0;
        int loop = 0;
        for (auto &tableName : tableVec)
        { 
            string sql = "select * from " + tableName;
            tablePstmt = conn->prepareStatement(sql);
            tableRes = tablePstmt->executeQuery();
            while (tableRes->next())
            {
                if (++num % 500000 == 0)
                {
                    cout <<"Loop="<<++loop << ",Num=" << num << ",Index=" << tableRes->getInt(1) << ",Id=" << tableRes->getInt64(2)
                         << ",Name=" << tableRes->getString(3) << ",Title=" << tableRes->getString(4) << endl;
                }
            }
            cout << getTime() << ",finished in retrieving from " << tableName << endl<<endl;
        }
        conn->close();
        cout << "IsClosed=" << conn->isClosed() << endl;
        cout << getTime() << ",finished in void Util::readSQL5()!" << endl;
    }
    catch (sql::SQLException &ex)
    {
        cout << "#ERR: SQLException in " << __FILE__ << "," << __FUNCTION__ << "," << __LINE__ << endl;
        cout << ex.what() << endl;
        cout << "Error code:" << ex.getErrorCode() << ",state:" << ex.getSQLState() << endl;
        return;
    }
}

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

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

//main.cpp

#include "Model/Util.h"

void readTable5();


int main(int args,char **argv)
{
    try
    {
        readTable5();
    }
    catch(const std::exception& e)
    {
        std::cerr << e.what() << '\n';
    }
    
}

void readTable5()
{
    Util ul;
    ul.readSQL5();
}

Compile:

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

Run

time ./h1 -1;

标签：std,Util,read,res,C++,char,sql,table,include
来源： https://www.cnblogs.com/Fred1987/p/16378165.html

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