mkvoya
/
rt-thread
forked from springcute/rt-thread
0
0
Fork 1
Code Issues Pull Requests Packages Projects Releases Wiki Activity
rt-thread/components/tpcc-sqlite/start.c

815 lines
25 KiB
C
Raw Permalink Blame History

/*
* main.pc
* driver for the tpcc transactions
*/
#include <rtdevice.h>
#include <rtthread.h>
#include <board.h>
#include <sys/signal.h>
// #include "support.h"
// #include "rthist.h"
// #include "sb_percentile.h"
// #include "sequence.h"
// #include "spt_proc.h"
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/time.h>
#include <signal.h>
#include <pthread.h>
#include <fcntl.h>
#include <time.h>
#include <sqlite3.h>
#include "tpc.h"
#include "trans_if.h"
#include "spt_proc.h"
#include "sequence.h"
#include "rthist.h"
#include "sb_percentile.h"
/* Global SQL Variables */
sqlite3 **ctx;
sqlite3_stmt ***stmt;
#define DB_STRING_MAX 128
#define MAX_CLUSTER_SIZE 128
int num_ware;
int num_conn;
int lampup_time;
int measure_time;
int num_node; /* number of servers that consists of cluster i.e. RAC (0:normal mode)*/
#define NUM_NODE_MAX 8
char node_string[NUM_NODE_MAX][DB_STRING_MAX];
int time_count;
int PRINT_INTERVAL=10;
int multi_schema = 0;
int multi_schema_offset = 0;
int success[5];
int late[5];
int retry[5];
int failure[5];
int* success2[5];
int* late2[5];
int* retry2[5];
int* failure2[5];
int success2_sum[5];
int late2_sum[5];
int retry2_sum[5];
int failure2_sum[5];
int prev_s[5];
int prev_l[5];
double max_rt[5];
double total_rt[5];
double cur_max_rt[5];
double prev_total_rt[5];
#define RTIME_NEWORD 5
#define RTIME_PAYMENT 5
#define RTIME_ORDSTAT 5
#define RTIME_DELIVERY 80
#define RTIME_SLEV 20
int rt_limit[5] = {
RTIME_NEWORD,
RTIME_PAYMENT,
RTIME_ORDSTAT,
RTIME_DELIVERY,
RTIME_SLEV
};
sb_percentile_t local_percentile;
int activate_transaction;
double time_taken;
clock_t time_start;
clock_t time_end;
int counting_on;
int num_trans=5000;
long clk_tck;
// int is_local = 0; /* "1" mean local */
int valuable_flg = 0; /* "1" mean valuable ratio */
// extern const char* db_path = "tpcc.db";
extern const char * db_path;
extern int is_local;
typedef struct
{
int number;
} thread_arg;
int thread_main(thread_arg*);
void alarm_handler(int signum);
void alarm_dummy();
void start( )
{
int i, k, t_num, arg_offset, c;
long j;
float f;
pthread_t *t;
thread_arg *thd_arg;
timer_t timer;
// struct itimerval itval;
// struct sigaction sigact;
int fd, seed;
printf("CHECKING IF SQLITE IS THREADSAFE: RETURN VALUE = %d\n", sqlite3_threadsafe());
// sqlite3_vfs_register(sqlite3_vfs_find("unix-none"), 1);
sqlite3_initialize();
printf("***************************************\n");
printf("*** ###easy### TPC-C Load Generator ***\n");
printf("***************************************\n");
/* initialize */
hist_init();
activate_transaction = 1;
counting_on = 1;
for ( i=0; i<5; i++ ){
success[i]=0;
late[i]=0;
retry[i]=0;
failure[i]=0;
prev_s[i]=0;
prev_l[i]=0;
prev_total_rt[i] = 0.0;
max_rt[i]=0.0;
total_rt[i]=0.0;
}
/* dummy initialize*/
num_ware = 3;
num_conn = 1;
lampup_time = 10;
measure_time = 20;
/* number of node (default 0) */
num_node = 0;
arg_offset = 0;
// clk_tck = sysconf(_SC_CLK_TCK);
clk_tck = 1000;
/* Parse args */
// while ( (c = getopt(argc, argv, "w:c:r:l:i:m:o:t:d:0:1:2:3:4:")) != -1) {
// switch (c) {
// case 'w':
// printf ("option w with value '%s'\n", optarg);
// num_ware = atoi(optarg);
// break;
// case 'c':
// printf ("option c with value '%s'\n", optarg);
// num_conn = atoi(optarg);
// break;
// case 'r':
// printf ("option r with value '%s'\n", optarg);
// lampup_time = atoi(optarg);
// break;
// case 'l':
// printf ("option l with value '%s'\n", optarg);
// measure_time = atoi(optarg);
// break;
// case 'm':
// printf ("option m (multiple schemas) with value '%s'\n", optarg);
// multi_schema = atoi(optarg);
// break;
// case 'o':
// printf ("option o (multiple schemas offset) with value '%s'\n", optarg);
// multi_schema_offset = atoi(optarg);
// break;
// case 't':
// printf ("option t (number of transactions) with value '%s'\n", optarg);
// num_trans = atoi(optarg);
// break;
// case 'i':
// printf ("option i with value '%s'\n", optarg);
// PRINT_INTERVAL = atoi(optarg);
// break;
// case 'd':
// printf ("option d with value '%s'\n", optarg);
// db_path = optarg;
// break;
// case '0':
// printf ("option 0 (response time limit for transaction 0) '%s'\n", optarg);
// rt_limit[0] = atoi(optarg);
// break;
// case '1':
// printf ("option 1 (response time limit for transaction 1) '%s'\n", optarg);
// rt_limit[1] = atoi(optarg);
// break;
// case '2':
// printf ("option 2 (response time limit for transaction 2) '%s'\n", optarg);
// rt_limit[2] = atoi(optarg);
// break;
// case '3':
// printf ("option 3 (response time limit for transaction 3) '%s'\n", optarg);
// rt_limit[3] = atoi(optarg);
// break;
// case '4':
// printf ("option 4 (response time limit for transaction 4) '%s'\n", optarg);
// rt_limit[4] = atoi(optarg);
// break;
// case '?':
// printf("Usage: tpcc_start -w warehouses -c connections -r warmup_time -l running_time -i report_interval\n");
// exit(0);
// default:
// printf ("?? getopt returned character code 0%o ??\n", c);
// }
// }
// if (optind < argc) {
// printf ("non-option ARGV-elements: ");
// while (optind < argc)
// printf ("%s ", argv[optind++]);
// printf ("\n");
// }
/*
if ((num_node == 0)&&(argc == 14)) {
valuable_flg = 1;
}
if ((num_node == 0)&&(valuable_flg == 0)&&(argc != 9)) {
fprintf(stderr, "\n usage: tpcc_start [server] [DB] [user] [pass] [warehouse] [connection] [rampup] [measure]\n");
exit(1);
}
if ( strlen(argv[1]) >= DB_STRING_MAX ) {
fprintf(stderr, "\n server phrase is too long\n");
exit(1);
}
if ( strlen(argv[2]) >= DB_STRING_MAX ) {
fprintf(stderr, "\n DBname phrase is too long\n");
exit(1);
}
if ( strlen(argv[3]) >= DB_STRING_MAX ) {
fprintf(stderr, "\n user phrase is too long\n");
exit(1);
}
if ( strlen(argv[4]) >= DB_STRING_MAX ) {
fprintf(stderr, "\n pass phrase is too long\n");
exit(1);
}
if ((num_ware = atoi(argv[5 + arg_offset])) <= 0) {
fprintf(stderr, "\n expecting positive number of warehouses\n");
exit(1);
}
if ((num_conn = atoi(argv[6 + arg_offset])) <= 0) {
fprintf(stderr, "\n expecting positive number of connections\n");
exit(1);
}
if ((lampup_time = atoi(argv[7 + arg_offset])) < 0) {
fprintf(stderr, "\n expecting positive number of lampup_time [sec]\n");
exit(1);
}
if ((measure_time = atoi(argv[8 + arg_offset])) < 0) {
fprintf(stderr, "\n expecting positive number of measure_time [sec]\n");
exit(1);
}
if (parse_host_get_port(&port, argv[1]) < 0) {
fprintf(stderr, "cannot prase the host: %s\n", argv[1]);
exit(1);
}
strcpy( db_string, argv[2] );
strcpy( db_user, argv[3] );
strcpy( db_password, argv[4] );
*/
// if(valuable_flg==1){
// if( (atoi(argv[9 + arg_offset]) < 0)||(atoi(argv[10 + arg_offset]) < 0)||(atoi(argv[11 + arg_offset]) < 0)
// ||(atoi(argv[12 + arg_offset]) < 0)||(atoi(argv[13 + arg_offset]) < 0) ) {
// fprintf(stderr, "\n expecting positive number of ratio parameters\n");
// exit(1);
// }
// }
if( num_node > 0 ){
if( num_ware % num_node != 0 ){
fprintf(stderr, "\n [warehouse] value must be devided by [num_node].\n");
}
if( num_conn % num_node != 0 ){
fprintf(stderr, "\n [connection] value must be devided by [num_node].\n");
}
}
printf("<Parameters>\n");
printf(" [warehouse]: %d\n", num_ware);
printf(" [connection]: %d\n", num_conn);
printf(" [rampup]: %d (sec.)\n", lampup_time);
printf(" [measure]: %d (sec.)\n", measure_time);
// if(valuable_flg==1){
// printf(" [ratio]: %d:%d:%d:%d:%d\n", atoi(argv[9 + arg_offset]), atoi(argv[10 + arg_offset]),
// atoi(argv[11 + arg_offset]), atoi(argv[12 + arg_offset]), atoi(argv[13 + arg_offset]) );
// }
/* alarm initialize */
time_count = 0;
// itval.it_interval.tv_sec = PRINT_INTERVAL;
// itval.it_interval.tv_usec = 0;
// itval.it_value.tv_sec = PRINT_INTERVAL;
// itval.it_value.tv_usec = 0;
// sigact.sa_handler = alarm_handler;
// sigact.sa_flags = 0;
// sigemptyset(&sigact.sa_mask);
/* setup handler&timer */
// if( sigaction( SIGALRM, &sigact, NULL ) == -1 ) {
// fprintf(stderr, "error in sigaction()\n");
//
// }
// fd = open("/dev/urandom", O_RDONLY);
// if (fd == -1) {
// fd = open("/dev/random", O_RDONLY);
// if (fd == -1) {
struct timeval tv;
gettimeofday(&tv, NULL);
seed = (tv.tv_sec ^ tv.tv_usec) * tv.tv_sec * tv.tv_usec ^ tv.tv_sec;
// }else{
// read(fd, &seed, sizeof(seed));
// close(fd);
// }
// }else{
// read(fd, &seed, sizeof(seed));
// close(fd);
// }
SetSeed(seed);
if(valuable_flg==0){
seq_init(10,10,1,1,1); /* normal ratio */
}else{
// seq_init( atoi(argv[9 + arg_offset]), atoi(argv[10 + arg_offset]), atoi(argv[11 + arg_offset]),
// atoi(argv[12 + arg_offset]), atoi(argv[13 + arg_offset]) );
}
/* set up each counter */
for ( i=0; i<5; i++ ){
success2[i] = malloc( sizeof(int) * num_conn );
late2[i] = malloc( sizeof(int) * num_conn );
retry2[i] = malloc( sizeof(int) * num_conn );
failure2[i] = malloc( sizeof(int) * num_conn );
for ( k=0; k<num_conn; k++ ){
success2[i][k] = 0;
late2[i][k] = 0;
retry2[i][k] = 0;
failure2[i][k] = 0;
}
}
if (sb_percentile_init(&local_percentile, 100000, 1.0, 1e13))
return NULL;
/* set up threads */
t = malloc( sizeof(pthread_t) * num_conn );
if ( t == NULL ){
fprintf(stderr, "error at malloc(pthread_t)\n");
}
thd_arg = malloc( sizeof(thread_arg) * num_conn );
if( thd_arg == NULL ){
fprintf(stderr, "error at malloc(thread_arg)\n");
}
ctx = malloc( sizeof(sqlite3 *) * num_conn );
stmt = malloc( sizeof(sqlite3_stmt **) * num_conn );
for( i=0; i < num_conn; i++ ){
stmt[i] = malloc( sizeof(sqlite3_stmt *) * 40 );
}
if ( ctx == NULL ){
fprintf(stderr, "error at malloc(sql_context)\n");
}
/* EXEC SQL WHENEVER SQLERROR GOTO sqlerr; */
for( t_num=0; t_num < num_conn; t_num++ ){
thd_arg[t_num].number= t_num;
pthread_create( &t[t_num], NULL, (void *)thread_main, (void *)&(thd_arg[t_num]) );
}
printf("\nRAMP-UP TIME.(%d sec.)\n",lampup_time);
fflush(stdout);
sleep(lampup_time);
printf("\nMEASURING START.\n\n");
fflush(stdout);
/* sleep(measure_time); */
/* start timer */
// #ifndef _SLEEP_ONLY_
// if( setitimer(0, &itval, NULL) == -1 ) {
// fprintf(stderr, "error in setitimer()\n");
// }
// #endif
counting_on = 1;
/* wait signal */
/*
for(i = 0; i < (measure_time / PRINT_INTERVAL); i++ ) {
//while (activate_transaction) {
#ifndef _SLEEP_ONLY_
pause();
#else
sleep(PRINT_INTERVAL);
alarm_dummy();
#endif
}
*/
counting_on = 0;
// #ifndef _SLEEP_ONLY_
// /* stop timer */
// itval.it_interval.tv_sec = 0;
// itval.it_interval.tv_usec = 0;
// itval.it_value.tv_sec = 0;
// itval.it_value.tv_usec = 0;
// if( setitimer(0, &itval, NULL) == -1 ) {
// fprintf(stderr, "error in setitimer()\n");
// }
// #endif
printf("\nSTOPPING THREADS");
activate_transaction = 0;
/* wait threads' ending and close connections*/
for( i=0; i < num_conn; i++ ){
pthread_join( t[i], NULL );
}
printf("\n");
free(ctx);
for( i=0; i < num_conn; i++ ){
free(stmt[i]);
}
free(stmt);
free(t);
free(thd_arg);
//hist_report();
printf("\n<Raw Results>\n");
for ( i=0; i<5; i++ ){
printf(" [%d] sc:%d lt:%d rt:%d fl:%d avg_rt: %.1f (%d)\n",
i, success[i], late[i], retry[i], failure[i],
total_rt[i] / (success[i] + late[i]), rt_limit[i]);
}
printf(" in %d sec.\n", (measure_time / PRINT_INTERVAL) * PRINT_INTERVAL);
printf("\n<Raw Results2(sum ver.)>\n");
for( i=0; i<5; i++ ){
success2_sum[i] = 0;
late2_sum[i] = 0;
retry2_sum[i] = 0;
failure2_sum[i] = 0;
for( k=0; k<num_conn; k++ ){
success2_sum[i] += success2[i][k];
late2_sum[i] += late2[i][k];
retry2_sum[i] += retry2[i][k];
failure2_sum[i] += failure2[i][k];
}
}
for ( i=0; i<5; i++ ){
printf(" [%d] sc:%d lt:%d rt:%d fl:%d \n", i, success2_sum[i], late2_sum[i], retry2_sum[i], failure2_sum[i]);
}
printf("\n<Constraint Check> (all must be [OK])\n [transaction percentage]\n");
for ( i=0, j=0; i<5; i++ ){
j += (success[i] + late[i]);
}
f = 100.0 * (float)(success[1] + late[1])/(float)j;
printf(" Payment: %3.2f%% (>=43.0%%)",f);
if ( f >= 43.0 ){
printf(" [OK]\n");
}else{
printf(" [NG] *\n");
}
f = 100.0 * (float)(success[2] + late[2])/(float)j;
printf(" Order-Status: %3.2f%% (>= 4.0%%)",f);
if ( f >= 4.0 ){
printf(" [OK]\n");
}else{
printf(" [NG] *\n");
}
f = 100.0 * (float)(success[3] + late[3])/(float)j;
printf(" Delivery: %3.2f%% (>= 4.0%%)",f);
if ( f >= 4.0 ){
printf(" [OK]\n");
}else{
printf(" [NG] *\n");
}
f = 100.0 * (float)(success[4] + late[4])/(float)j;
printf(" Stock-Level: %3.2f%% (>= 4.0%%)",f);
if ( f >= 4.0 ){
printf(" [OK]\n");
}else{
printf(" [NG] *\n");
}
printf(" [response time (at least 90%% passed)]\n");
f = 100.0 * (float)success[0]/(float)(success[0] + late[0]);
printf(" New-Order: %3.2f%% ",f);
if ( f >= 90.0 ){
printf(" [OK]\n");
}else{
printf(" [NG] *\n");
}
f = 100.0 * (float)success[1]/(float)(success[1] + late[1]);
printf(" Payment: %3.2f%% ",f);
if ( f >= 90.0 ){
printf(" [OK]\n");
}else{
printf(" [NG] *\n");
}
f = 100.0 * (float)success[2]/(float)(success[2] + late[2]);
printf(" Order-Status: %3.2f%% ",f);
if ( f >= 90.0 ){
printf(" [OK]\n");
}else{
printf(" [NG] *\n");
}
f = 100.0 * (float)success[3]/(float)(success[3] + late[3]);
printf(" Delivery: %3.2f%% ",f);
if ( f >= 90.0 ){
printf(" [OK]\n");
}else{
printf(" [NG] *\n");
}
f = 100.0 * (float)success[4]/(float)(success[4] + late[4]);
printf(" Stock-Level: %3.2f%% ",f);
if ( f >= 90.0 ){
printf(" [OK]\n");
}else{
printf(" [NG] *\n");
}
printf("\n<TpmC>\n");
f = (float)(success[0] + late[0]) * 60.0
/ (float)((measure_time / PRINT_INTERVAL) * PRINT_INTERVAL);
printf(" %.3f TpmC\n",f);
printf("\nTime taken\n");
time_taken = ((double) (time_end - time_start)) / CLOCKS_PER_SEC;
printf(" %.3f seconds\n", time_taken);
sqlerr:
fprintf(stdout, "error at main\n");
error(ctx[i],0);
}
MSH_CMD_EXPORT(start, start tpcc test);
void alarm_handler(int signum)
{
int i;
int s[5],l[5];
double rt90[5];
double trt[5];
double percentile_val;
double percentile_val99;
for( i=0; i<5; i++ ){
s[i] = success[i];
l[i] = late[i];
trt[i] = total_rt[i];
//rt90[i] = hist_ckp(i);
}
time_count += PRINT_INTERVAL;
percentile_val = sb_percentile_calculate(&local_percentile, 95);
percentile_val99 = sb_percentile_calculate(&local_percentile, 99);
sb_percentile_reset(&local_percentile);
// printf("%4d, %d:%.3f|%.3f(%.3f), %d:%.3f|%.3f(%.3f), %d:%.3f|%.3f(%.3f), %d:%.3f|%.3f(%.3f), %d:%.3f|%.3f(%.3f)\n",
printf("%4d, trx: %d, 95%: %.3f, 99%: %.3f, max_rt: %.3f, %d|%.3f, %d|%.3f, %d|%.3f, %d|%.3f\n",
time_count,
( s[0] + l[0] - prev_s[0] - prev_l[0] ), percentile_val,percentile_val99,
(double)cur_max_rt[0],
( s[1] + l[1] - prev_s[1] - prev_l[1] ),
(double)cur_max_rt[1],
( s[2] + l[2] - prev_s[2] - prev_l[2] ),
(double)cur_max_rt[2],
( s[3] + l[3] - prev_s[3] - prev_l[3] ),
(double)cur_max_rt[3],
( s[4] + l[4] - prev_s[4] - prev_l[4] ),
(double)cur_max_rt[4]
);
fflush(stdout);
for( i=0; i<5; i++ ){
prev_s[i] = s[i];
prev_l[i] = l[i];
prev_total_rt[i] = trt[i];
cur_max_rt[i]=0.0;
}
}
void alarm_dummy()
{
int i;
int s[5],l[5];
float rt90[5];
for( i=0; i<5; i++ ){
s[i] = success[i];
l[i] = late[i];
rt90[i] = hist_ckp(i);
}
time_count += PRINT_INTERVAL;
printf("%4d, %d(%d):%.2f, %d(%d):%.2f, %d(%d):%.2f, %d(%d):%.2f, %d(%d):%.2f\n",
time_count,
( s[0] + l[0] - prev_s[0] - prev_l[0] ),
( l[0] - prev_l[0] ),
rt90[0],
( s[1] + l[1] - prev_s[1] - prev_l[1] ),
( l[1] - prev_l[1] ),
rt90[1],
( s[2] + l[2] - prev_s[2] - prev_l[2] ),
( l[2] - prev_l[2] ),
rt90[2],
( s[3] + l[3] - prev_s[3] - prev_l[3] ),
( l[3] - prev_l[3] ),
rt90[3],
( s[4] + l[4] - prev_s[4] - prev_l[4] ),
( l[4] - prev_l[4] ),
rt90[4]
);
fflush(stdout);
for( i=0; i<5; i++ ){
prev_s[i] = s[i];
prev_l[i] = l[i];
}
}
int thread_main (thread_arg* arg)
{
int t_num= arg->number;
int r,i;
sqlite3* sqlite3_db = NULL;
/* EXEC SQL WHENEVER SQLERROR GOTO sqlerr;*/
// printf("Using schema: %s\n", db_string_full);
/* exec sql connect :connect_string; */
printf("%s: opening db, thread id = %lu\n", __func__, pthread_self());
sqlite3_open(db_path, &sqlite3_db);
printf("%s: opened db, thread id = %lu\n", __func__, pthread_self());
sqlite3_exec(sqlite3_db, "PRAGMA journal_mode = OFF;", 0, 0, 0);
if(!sqlite3_db) {
goto sqlerr;
}
ctx[t_num] = sqlite3_db;
printf("go prepare here\n");
/* Prepare ALL of SQLs */
if( sqlite3_prepare_v2(sqlite3_db, "SELECT c_discount, c_last, c_credit, w_tax FROM customer, warehouse WHERE w_id = ? AND c_w_id = w_id AND c_d_id = ? AND c_id = ?", -1, &stmt[t_num][0], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "SELECT d_next_o_id, d_tax FROM district WHERE d_id = ? AND d_w_id = ?", -1, &stmt[t_num][1], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "UPDATE district SET d_next_o_id = ? + 1 WHERE d_id = ? AND d_w_id = ?", -1, &stmt[t_num][2], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "INSERT INTO orders (o_id, o_d_id, o_w_id, o_c_id, o_entry_d, o_ol_cnt, o_all_local) VALUES(?, ?, ?, ?, ?, ?, ?)", -1, &stmt[t_num][3], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "INSERT INTO new_orders (no_o_id, no_d_id, no_w_id) VALUES (?,?,?)", -1, &stmt[t_num][4], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "SELECT i_price, i_name, i_data FROM item WHERE i_id = ?", -1, &stmt[t_num][5], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "SELECT s_quantity, s_data, s_dist_01, s_dist_02, s_dist_03, s_dist_04, s_dist_05, s_dist_06, s_dist_07, s_dist_08, s_dist_09, s_dist_10 FROM stock WHERE s_i_id = ? AND s_w_id = ?", -1, &stmt[t_num][6], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "UPDATE stock SET s_quantity = ? WHERE s_i_id = ? AND s_w_id = ?", -1, &stmt[t_num][7], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "INSERT INTO order_line (ol_o_id, ol_d_id, ol_w_id, ol_number, ol_i_id, ol_supply_w_id, ol_quantity, ol_amount, ol_dist_info) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)", -1, &stmt[t_num][8], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "UPDATE warehouse SET w_ytd = w_ytd + ? WHERE w_id = ?", -1, &stmt[t_num][9], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "SELECT w_street_1, w_street_2, w_city, w_state, w_zip, w_name FROM warehouse WHERE w_id = ?", -1, &stmt[t_num][10], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "UPDATE district SET d_ytd = d_ytd + ? WHERE d_w_id = ? AND d_id = ?", -1, &stmt[t_num][11], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "SELECT d_street_1, d_street_2, d_city, d_state, d_zip, d_name FROM district WHERE d_w_id = ? AND d_id = ?", -1, &stmt[t_num][12], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "SELECT count(c_id) FROM customer WHERE c_w_id = ? AND c_d_id = ? AND c_last = ?", -1, &stmt[t_num][13], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "SELECT c_id FROM customer WHERE c_w_id = ? AND c_d_id = ? AND c_last = ? ORDER BY c_first", -1, &stmt[t_num][14], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "SELECT c_first, c_middle, c_last, c_street_1, c_street_2, c_city, c_state, c_zip, c_phone, c_credit, c_credit_lim, c_discount, c_balance, c_since FROM customer WHERE c_w_id = ? AND c_d_id = ? AND c_id = ?", -1, &stmt[t_num][15], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "SELECT c_data FROM customer WHERE c_w_id = ? AND c_d_id = ? AND c_id = ?", -1, &stmt[t_num][16], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "UPDATE customer SET c_balance = ?, c_data = ? WHERE c_w_id = ? AND c_d_id = ? AND c_id = ?", -1, &stmt[t_num][17], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "UPDATE customer SET c_balance = ? WHERE c_w_id = ? AND c_d_id = ? AND c_id = ?", -1, &stmt[t_num][18], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "INSERT INTO history(h_c_d_id, h_c_w_id, h_c_id, h_d_id, h_w_id, h_date, h_amount, h_data) VALUES(?, ?, ?, ?, ?, ?, ?, ?)", -1, &stmt[t_num][19], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "SELECT count(c_id) FROM customer WHERE c_w_id = ? AND c_d_id = ? AND c_last = ?", -1, &stmt[t_num][20], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "SELECT c_balance, c_first, c_middle, c_last FROM customer WHERE c_w_id = ? AND c_d_id = ? AND c_last = ? ORDER BY c_first", -1, &stmt[t_num][21], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "SELECT c_balance, c_first, c_middle, c_last FROM customer WHERE c_w_id = ? AND c_d_id = ? AND c_id = ?", -1, &stmt[t_num][22], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "SELECT o_id, o_entry_d, COALESCE(o_carrier_id,0) FROM orders WHERE o_w_id = ? AND o_d_id = ? AND o_c_id = ? AND o_id = (SELECT MAX(o_id) FROM orders WHERE o_w_id = ? AND o_d_id = ? AND o_c_id = ?)", -1, &stmt[t_num][23], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "SELECT ol_i_id, ol_supply_w_id, ol_quantity, ol_amount, ol_delivery_d FROM order_line WHERE ol_w_id = ? AND ol_d_id = ? AND ol_o_id = ?", -1, &stmt[t_num][24], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "SELECT COALESCE(MIN(no_o_id),0) FROM new_orders WHERE no_d_id = ? AND no_w_id = ?", -1, &stmt[t_num][25], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "DELETE FROM new_orders WHERE no_o_id = ? AND no_d_id = ? AND no_w_id = ?", -1, &stmt[t_num][26], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "SELECT o_c_id FROM orders WHERE o_id = ? AND o_d_id = ? AND o_w_id = ?", -1, &stmt[t_num][27], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "UPDATE orders SET o_carrier_id = ? WHERE o_id = ? AND o_d_id = ? AND o_w_id = ?", -1, &stmt[t_num][28], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "UPDATE order_line SET ol_delivery_d = ? WHERE ol_o_id = ? AND ol_d_id = ? AND ol_w_id = ?", -1, &stmt[t_num][29], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "SELECT SUM(ol_amount) FROM order_line WHERE ol_o_id = ? AND ol_d_id = ? AND ol_w_id = ?", -1, &stmt[t_num][30], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "UPDATE customer SET c_balance = c_balance + ? , c_delivery_cnt = c_delivery_cnt + 1 WHERE c_id = ? AND c_d_id = ? AND c_w_id = ?", -1, &stmt[t_num][31], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "SELECT d_next_o_id FROM district WHERE d_id = ? AND d_w_id = ?", -1, &stmt[t_num][32], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "SELECT DISTINCT ol_i_id FROM order_line WHERE ol_w_id = ? AND ol_d_id = ? AND ol_o_id < ? AND ol_o_id >= (? - 20)", -1, &stmt[t_num][33], NULL) != SQLITE_OK) goto sqlerr;
if( sqlite3_prepare_v2(sqlite3_db, "SELECT count(*) FROM stock WHERE s_w_id = ? AND s_i_id = ? AND s_quantity < ?", -1, &stmt[t_num][34], NULL) != SQLITE_OK) goto sqlerr;
INITIALIZE_TIMERS();
time_start = clock();
for (i = 0; i < num_trans; i++) {
printf("trans num:%d\n",i);
if( sqlite3_exec(ctx[t_num], "BEGIN TRANSACTION;", NULL, NULL, NULL) != SQLITE_OK) goto sqlerr;
r = driver(t_num);
/* EXEC SQL COMMIT WORK; */
if( sqlite3_exec(ctx[t_num], "COMMIT;", NULL, NULL, NULL) != SQLITE_OK) goto sqlerr;
}
PRINT_TIME();
time_end = clock();
for(i=0;i<40;i++){
sqlite3_reset(stmt[t_num][i]);
}
/* EXEC SQL DISCONNECT; */
sqlite3_close(ctx[t_num]);
printf(".");
fflush(stdout);
return(r);
sqlerr:
fprintf(stdout, "error at thread_main\n");
printf("%s: error: %s\n", __func__, sqlite3_errmsg(ctx[t_num]));
//error(ctx[t_num],0);
return(0);
}
Reference in New Issue View Git Blame Copy Permalink