COMMON/src/readmy.c

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


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