/*
my_tcpb tpc-B SQL
v. 1.0.0

Programma per effettuare la transazione standard (TPC-B)

Il suo utilizzo consente di effettuare prove parametriche sull'utilizzo di
MySQL in parallelo da parte di piu' utenti.

Versione con Stored Procedures (utilizzabile solo dalla 5.0)

meo@bogliolo.name
*/

#include <stdio.h>
/* #include <stdlib.h> */

#include "mysql.h"

int     Bid;
int     Tid;
int     Aid;
int     delta;
double  Abalance;

char    username[40];
char    passwd[40];
char    hostname[40];
char    query[256];

MYSQL m;
MYSQL_RES *results;
MYSQL_ROW record;

int             i;
int             ntimes;
int             sleeptime;
int             logging;
int             scale;

main(argc, argv)
int argc;
char **argv;
{

if (argc != 7)
        {
        if (argc != 8)
                {
                printf("TPC-B for MySQL database: version 1.0.1 - SQL\n");
                printf("Usage: mysubmit_SP user passwd hostname sleeptime times log [scale] \n");
                exit(2);
                }
        }
strcpy(username, argv[1]);
strcpy(passwd, argv[2]);
strcpy(hostname, argv[3]);
sscanf(argv[4], "%d", &sleeptime);
sscanf(argv[5], "%d", &ntimes);
sscanf(argv[6], "%d", &logging);
if (argc == 7)
        {
        scale=1;
        }
else
        {
        sscanf(argv[7], "%d", &scale);
        }

if ( ntimes < 1 )
        {
        printf("Usage: mysubmit user passwd hostname sleeptime times log [scale] \n");
        printf("times must be more than 0\n");
        exit(2);
        }

if ( sleeptime < 0 )
        {
        printf("Usage: mysubmit user passwd hostname sleeptime times log [scale] \n");
        printf("sleeptime must be more or equal than 0\n");
        exit(2);
        }

if ( scale < 1 )
        {
        printf("Usage: mysubmit user passwd hostname sleeptime times log [scale] \n");
        printf("scale must be more than 0\n");
        exit(2);
        }

srand(getpid());

mysql_init(&m);

if (!mysql_real_connect(&m, hostname, username, passwd, "bench", 0,NULL,0))
        {
        fprintf(stderr, "Error in connect: %s\n",
                        mysql_error(&m));
        exit(1);
        }

mysql_autocommit(&m, 0);
if (mysql_query(&m, "set transaction isolation level read committed"))
        {
        fprintf(stderr, "Error in set isolation: %s\n",
        mysql_error(&m));
        }

while (ntimes--)
        {

        sleep(sleeptime);

        Bid = rand();
        Bid = Bid - Bid/scale*scale;

        Tid = rand();
        Tid = Tid - Tid/10*10;
        Tid = Tid + 10*Bid;

        Aid = rand();
        Aid = Aid - Aid/100000*100000;
        Aid = Aid +     100000*Bid;

        delta = rand();
        delta = delta - delta/2000000*2000000;
        delta = delta       - 1000000;

        sprintf(query, "CALL B_SP_Tran_1(%i, %i, %i, %i, %f )",
		Aid, Bid, Tid, delta, Abalance);
        if (mysql_query(&m, query))
                { fprintf(stderr, "Error in CALL SP: %s\n", mysql_error(&m)); }

        }

mysql_close(&m);

exit(0);

}