MYSQL開発パフォーマンス調査：バッチデータ挿入の最適化方法

TBL_TEST(id) VALUES(1)に挿入します。

TBL_TEST (id) に値 (1)、(2)、(3) を挿入する

--テーブルステートメントの作成 CREATE TABLE tbl_test 
（
  pri_key varchar(30)、 
  nor_char char(30)、 
  最大数 10進数(8,0) 
  long_num DECIMAL(12, 0)、 
  rec_upd_ts タイムスタンプ
);

#include <文字列.h>
#include <iostream>
#include <mysql.h>
#include <sys/time.h>
#include <sstream>
#include <ベクター>
 
名前空間 std を使用します。
 
#STRING_LEN 30 を定義します
  
char pri_key[STRING_LEN] = "123456"; 
char nor_char [STRING_LEN] = "abcabc"; 
char rec_upd_ts [STRING_LEN] = "NOW()"; 
 
bool SubTimeval(timeval &result, timeval &begin, timeval &end)
{
  begin.tv_sec>end.tv_sec の場合、false を返します。
 
  もし ( (begin.tv_sec == end.tv_sec) && (begin.tv_usec > end.tv_usec) )  
    false を返します。
 
  result.tv_sec = ( end.tv_sec - begin.tv_sec );  
  result.tv_usec = ( end.tv_usec - begin.tv_usec );  
 
  （結果.tv_usec<0）の場合{
    結果.tv_sec--;
    結果.tv_usec+=1000000;} 
  true を返します。
}
 
int main(int argc, char ** argv)
{
  INT32 戻り値 = 0;
  char errmsg[200] = {0};
  int sqlコード = 0;
 
  timeval tBegin、tEnd、tDiff;
   
  const char* precompile_statment2 = "`tbl_test`( pri_key、nor_char、max_num、long_num、rec_upd_ts) VALUES(?、?、?、?、?) に INSERT INTO";
   
  MYSQL 接続;
  mysql_init(&conn);
   
  (mysql_real_connect(&conn, "127.0.0.1", "dba", "abcdefg", "TESTDB", 3306, NULL, 0) == NULL)の場合
  {
    fprintf(stderr, "mysql_real_connect, 2 が失敗しました\n");
    終了(0);
  }
   
  MYSQL_STMT *stmt = mysql_stmt_init(&conn);
  if (!ステートメント)
  {
   fprintf(stderr, "mysql_stmt_init, 2 が失敗しました\n");
   fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
   終了(0);
  }
   
  if (mysql_stmt_prepare(stmt、precompile_statment2、strlen(precompile_statment2)))
  {
   fprintf(stderr, "mysql_stmt_prepare, 2 が失敗しました\n");
   fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
   終了(0);
  }
   
  整数 i = 0; 
  整数最大数 = 3;
  定数 int FIELD_NUM = 5;
  (i < 最大数) の間
  {
    //MYSQL_BIND バインド[196] = {0};
    MYSQL_BIND バインド[フィールド番号];
    memset(bind, 0, FIELD_NUM * sizeof(MYSQL_BIND));
   
    符号なしlong str_length = strlen(pri_key);
    バインド[0].buffer_type = MYSQL_TYPE_STRING;
    bind[0].buffer = (char *)pri_key;
    bind[0].buffer_length = STRING_LEN;
    バインド[0].is_null = 0;
    バインド[0].長さ = &str_length;
     
    符号なしlong str_length_nor = strlen(nor_char);
    バインド[1].buffer_type = MYSQL_TYPE_STRING;
    バインド[1].バッファ = (char *)nor_char;
    バインド[1].buffer_length = STRING_LEN;
    バインド[1].is_null = 0;
    バインド[1].length = &str_length_nor;
     
    バインド[2].buffer_type = MYSQL_TYPE_LONG;
    bind[2].buffer = (char*)&max_num;
    バインド[2].is_null = 0;
    バインド[2].長さ = 0;
     
    バインド[3].buffer_type = MYSQL_TYPE_LONG;
    bind[3].buffer = (char*)&max_num;
    バインド[3].is_null = 0;
    バインド[3].長さ = 0;
     
    MYSQL_TIME ts;
    ts.year = 2002;
    ts.月 = 02;
    ts.day = 03;
    ts.時間 = 10;
    ts.分 = 45;
    ts.秒 = 20;
     
    符号なしロングstr_length_time = strlen(rec_upd_ts);
    バインド[4].buffer_type = MYSQL_TYPE_TIMESTAMP;
    bind[4].buffer = (char *)&ts;
    バインド[4].is_null = 0;
    バインド[4].長さ = 0;
     
    if (mysql_stmt_bind_param(stmt, bind))
    {
      fprintf(stderr, "mysql_stmt_bind_param, 2 が失敗しました\n");
      fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
      終了(0);
    }
     
    cout << "実行前\n";
    (mysql_stmt_execute(stmt)) の場合
    {
     fprintf(stderr, "mysql_stmt_execute, 2 が失敗しました\n");
     fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
     終了(0);
    }
    cout << "実行後\n";
     
    私は++;
  }
   
  mysql_commit(&conn);
   
  mysql_stmt_close(stmt);
 
  0を返します。  
}