COMMON/src/qumy.c

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <mysql.h>

short int qumy(char *db, const char *myquery){
    int debug = 0;
    if ( debug ) printf("Connecting to database... \n"); 
    MYSQL *pConnection;
    MYSQL_RES *pResult;
    MYSQL_ROW Row;
    short int retval = 0;
    int t;
    int r;
    pConnection = mysql_init(NULL);
    if(!pConnection) return(1);
    //
    int connect = (int)mysql_real_connect(pConnection,"srv-g2-01.ts.infn.it","root","Calo0%Ts",db,0,NULL,0);    
    if( !connect ) return(2);    
    if ( debug ) printf("...connected! \n\n");
    if ( debug ) printf("The query is:\n              \"%s\" \n",myquery);
    int errqu = mysql_query(pConnection,myquery);
    if ( !errqu ) {
        pResult = mysql_store_result(pConnection);
        for( r=0; r < mysql_field_count(pConnection); r++){ 
            Row = mysql_fetch_row(pResult);
            if( Row == NULL ) break;
            int section = 0;
            int fromtime = 0;
            int totime = 0;
            int calibtime = 0;
            int obtjump = 0;
            char *file = 0;
            for( t = 0; t < mysql_num_fields(pResult); t++){
                if ( t == 1 ) section = atoi(Row[t]);
                if ( t == 2 ) obtjump = atoi(Row[t]);
                if ( t == 3 ) fromtime = atoi(Row[t]);
                if ( t == 4 ) totime = atoi(Row[t]);
                if ( t == 5 ) calibtime = atoi(Row[t]);
                if ( t == 6 ) file = Row[t];
            };
            if ( debug ) printf(" section %i from time %i to time %i use calibration at time %i from file %s ",section,fromtime,totime,calibtime,file);
            if ( debug ) printf("\n");
        };
        mysql_free_result(pResult);
        retval = 0;
    } else {
        if ( debug ) printf(" errqu = %i \n",errqu);
        retval = 3;
    };
    if ( debug ) printf("\nClose the connection... \n");
    mysql_close(pConnection);    
    if ( debug ) printf("...connection terminated!\n"); 
    return(retval);
}
1	#include <stdio.h>
2	#include <stdlib.h>
3	#include <string.h>
4	#include <mysql.h>
5
6	short int qumy(char db, const char myquery){
7	int debug = 0;
8	if ( debug ) printf("Connecting to database... \n");
9	MYSQL *pConnection;
10	MYSQL_RES *pResult;
11	MYSQL_ROW Row;
12	short int retval = 0;
13	int t;
14	int r;
15	pConnection = mysql_init(NULL);
16	if(!pConnection) return(1);
17	//
18	int connect = (int)mysql_real_connect(pConnection,"srv-g2-01.ts.infn.it","root","Calo0%Ts",db,0,NULL,0);
19	if( !connect ) return(2);
20	if ( debug ) printf("...connected! \n\n");
21	if ( debug ) printf("The query is:\n \"%s\" \n",myquery);
22	int errqu = mysql_query(pConnection,myquery);
23	if ( !errqu ) {
24	pResult = mysql_store_result(pConnection);
25	for( r=0; r < mysql_field_count(pConnection); r++){
26	Row = mysql_fetch_row(pResult);
27	if( Row == NULL ) break;
28	int section = 0;
29	int fromtime = 0;
30	int totime = 0;
31	int calibtime = 0;
32	int obtjump = 0;
33	char *file = 0;
34	for( t = 0; t < mysql_num_fields(pResult); t++){
35	if ( t == 1 ) section = atoi(Row[t]);
36	if ( t == 2 ) obtjump = atoi(Row[t]);
37	if ( t == 3 ) fromtime = atoi(Row[t]);
38	if ( t == 4 ) totime = atoi(Row[t]);
39	if ( t == 5 ) calibtime = atoi(Row[t]);
40	if ( t == 6 ) file = Row[t];
41	};
42	if ( debug ) printf(" section %i from time %i to time %i use calibration at time %i from file %s ",section,fromtime,totime,calibtime,file);
43	if ( debug ) printf("\n");
44	};
45	mysql_free_result(pResult);
46	retval = 0;
47	} else {
48	if ( debug ) printf(" errqu = %i \n",errqu);
49	retval = 3;
50	};
51	if ( debug ) printf("\nClose the connection... \n");
52	mysql_close(pConnection);
53	if ( debug ) printf("...connection terminated!\n");
54	return(retval);
55	}