/************************************************************************* * * * YAP Prolog * * * * Yap Prolog was developed at NCCUP - Universidade do Porto * * * * Copyright L.Damas, V.S.Costa and Universidade do Porto 1985-1997 * * * ************************************************************************** * * * File: myddas_mysql.c * * Last rev: 22/03/05 * * mods: * * comments: Predicates for comunicating with a mysql database system * * * *************************************************************************/ #if defined MYDDAS_MYSQL #include #include #include #include #include "Yap.h" #include "Yatom.h" #include "cut_c.h" #include "myddas.h" #ifdef MYDDAS_STATS #include "myddas_structs.h" #include "myddas_statistics.h" #endif #define IS_SQL_INT(FIELD) FIELD == FIELD_TYPE_INT24 || \ FIELD == FIELD_TYPE_LONG || \ FIELD == FIELD_TYPE_LONGLONG || \ FIELD == FIELD_TYPE_SHORT || \ FIELD == FIELD_TYPE_TINY #define IS_SQL_FLOAT(FIELD) FIELD == FIELD_TYPE_DECIMAL || \ FIELD == FIELD_TYPE_DOUBLE || \ FIELD == FIELD_TYPE_FLOAT static Int null_id = 0; STATIC_PROTO(Int c_db_my_connect,(void)); STATIC_PROTO(Int c_db_my_disconnect,(void)); STATIC_PROTO(Int c_db_my_number_of_fields,(void)); STATIC_PROTO(Int c_db_my_get_attributes_types,(void)); STATIC_PROTO(Int c_db_my_query,(void)); STATIC_PROTO(Int c_db_my_table_write,(void)); STATIC_PROTO(Int c_db_my_row,(void)); STATIC_PROTO(Int c_db_my_row_cut,(void)); STATIC_PROTO(Int c_db_my_get_fields_properties,(void)); STATIC_PROTO(Int c_db_my_get_next_result_set,(void)); STATIC_PROTO(Int c_db_my_get_database,(void)); STATIC_PROTO(Int c_db_my_change_database,(void)); void Yap_InitMYDDAS_MySQLPreds(void) { /* db_connect: Host x User x Passwd x Database x Connection x ERROR_CODE */ Yap_InitCPred("c_db_my_connect", 7, c_db_my_connect, 0); /* db_number_of_fields: Relation x Connection x NumberOfFields */ Yap_InitCPred("c_db_my_number_of_fields",3, c_db_my_number_of_fields, 0); /* db_get_attributes_types: Relation x TypesList */ Yap_InitCPred("c_db_my_get_attributes_types", 3, c_db_my_get_attributes_types, 0); /* db_query: SQLQuery x ResultSet x Connection */ Yap_InitCPred("c_db_my_query", 5, c_db_my_query, 0); /* db_disconnect: Connection */ Yap_InitCPred("c_db_my_disconnect", 1,c_db_my_disconnect, 0); /* db_table_write: Result Set */ Yap_InitCPred("c_db_my_table_write", 1, c_db_my_table_write, 0); /* db_get_fields_properties: PredName x Connnection x PropertiesList*/ Yap_InitCPred("c_db_my_get_fields_properties",3,c_db_my_get_fields_properties,0); Yap_InitCPred("c_db_my_get_next_result_set",2,c_db_my_get_next_result_set,0); /* c_db_my_get_database: Connnection x DataBaseName */ Yap_InitCPred("c_db_my_get_database",2,c_db_my_get_database,0); /* c_db_my_change_database: Connnection x DataBaseName */ Yap_InitCPred("c_db_my_change_database",2,c_db_my_change_database,0); } void Yap_InitBackMYDDAS_MySQLPreds(void) { /* db_row: ResultSet x Arity x ListOfArgs */ Yap_InitCPredBackCut("c_db_my_row", 3, sizeof(Int), c_db_my_row, c_db_my_row, c_db_my_row_cut, 0); } static Int c_db_my_connect(void) { Term arg_host = Deref(ARG1); Term arg_user = Deref(ARG2); Term arg_passwd = Deref(ARG3); Term arg_database = Deref(ARG4); Term arg_port = Deref(ARG5); Term arg_socket = Deref(ARG6); Term arg_conn = Deref(ARG7); MYSQL *conn; MYDDAS_UTIL_CONNECTION new = NULL; char *host = AtomName(AtomOfTerm(arg_host)); char *user = AtomName(AtomOfTerm(arg_user)); char *passwd = AtomName(AtomOfTerm(arg_passwd)); char *database = AtomName(AtomOfTerm(arg_database)); Int port = IntegerOfTerm(arg_port); char *socket; if (IsNonVarTerm(arg_socket)) socket = AtomName(AtomOfTerm(arg_socket)); else socket = NULL; conn = mysql_init(NULL); if (conn == NULL) { #ifdef DEBUG printf("ERROR: ** c_db_my_connect ** error on init\n"); #endif return FALSE; } if (mysql_real_connect(conn, host, user, passwd, database, port, socket, CLIENT_MULTI_STATEMENTS) == NULL) { #ifdef DEBUG printf("ERROR: ** c_db_my_connect ** error on connect\n"); #endif return FALSE; } if (!Yap_unify(arg_conn, MkIntegerTerm((Int)conn))) return FALSE; else { /* Criar um novo no na lista de ligacoes*/ new = myddas_util_add_connection(conn,NULL); if (new == NULL){ #ifdef DEBUG printf("ERROR: ** c_db_my_connect ** Error allocating memory\n"); #endif return FALSE; } return TRUE; } } /* db_query: SQLQuery x ResultSet x Connection */ static Int c_db_my_query(void) { Term arg_sql_query = Deref(ARG1); Term arg_result_set = Deref(ARG2); Term arg_conn = Deref(ARG3); Term arg_mode = Deref(ARG4); Term arg_arity = Deref(ARG5); char *sql = AtomName(AtomOfTerm(arg_sql_query)); char *mode = AtomName(AtomOfTerm(arg_mode)); MYSQL *conn = (MYSQL *) (IntegerOfTerm(arg_conn)); MYSQL_RES *res_set; MyddasInt length=strlen(sql); #ifdef MYDDAS_STATS MYDDAS_UTIL_CONNECTION node = myddas_util_search_connection(conn); MyddasULInt count = 0; /* Count the number of querys made to the server */ MyddasULInt number_querys; MYDDAS_STATS_CON_GET_NUMBER_QUERIES_MADE(node,number_querys); MYDDAS_STATS_CON_SET_NUMBER_QUERIES_MADE(node,++number_querys); MYDDAS_STATS_CON_GET_NUMBER_QUERIES_MADE_COUNT(node,count); MYDDAS_STATS_CON_SET_NUMBER_QUERIES_MADE_COUNT(node,++count); /* Measure time spent by the MySQL Server processing the SQL Query */ MYDDAS_STATS_TIME start,end,total_time,diff; start = myddas_stats_walltime(); #endif /* Send query to server and process it */ if (mysql_real_query(conn, sql, length) != 0) { #ifdef DEBUG printf("ERROR: **c_db_my_query** Error on query! %s\n",sql); #endif return FALSE; } #ifdef MYDDAS_STATS /* Measure time spent by the MySQL Server processing the SQL Query */ end = myddas_stats_walltime(); MYDDAS_STATS_INITIALIZE_TIME_STRUCT(diff,time_copy); myddas_stats_subtract_time(diff,end,start); diff = myddas_stats_time_copy_to_final(diff); MYDDAS_FREE(end,struct myddas_stats_time_struct); MYDDAS_FREE(start,struct myddas_stats_time_struct); MYDDAS_STATS_CON_GET_TOTAL_TIME_DBSERVER(node,total_time); /* Automacally updates the MYDDAS_STRUCTURE */ myddas_stats_add_time(total_time,diff,total_time); MYDDAS_STATS_CON_GET_TOTAL_TIME_DBSERVER_COUNT(node,count); MYDDAS_STATS_CON_SET_TOTAL_TIME_DBSERVER_COUNT(node,++count); MYDDAS_STATS_TIME time = NULL; MYDDAS_STATS_CON_GET_LAST_TIME_DBSERVER(node,time); myddas_stats_move_time(diff,time); MYDDAS_STATS_CON_GET_LAST_TIME_DBSERVER_COUNT(node,count); MYDDAS_STATS_CON_SET_LAST_TIME_DBSERVER_COUNT(node,++count); #endif /* guardar os tuplos do lado do cliente */ if (strcmp(mode,"store_result")!=0) //True res_set = mysql_use_result(conn); else{ #ifdef MYDDAS_STATS /* Measure time spent by the MySQL Server transferring the result of the last query back to the client */ start = myddas_stats_walltime(); #endif res_set = mysql_store_result(conn); #ifdef MYDDAS_STATS /* Measure time spent by the MySQL Server transferring the result of the last query back to the client */ end = myddas_stats_walltime(); MYDDAS_STATS_INITIALIZE_TIME_STRUCT(diff,time_copy); myddas_stats_subtract_time(diff,end,start); diff = myddas_stats_time_copy_to_final(diff); MYDDAS_FREE(end,struct myddas_stats_time_struct); MYDDAS_FREE(start,struct myddas_stats_time_struct); MYDDAS_STATS_CON_GET_TOTAL_TIME_TRANSFERING(node,total_time); /* Automacally updates the MYDDAS_STRUCTURE */ myddas_stats_add_time(total_time,diff,total_time); MYDDAS_STATS_CON_GET_TOTAL_TIME_TRANSFERING_COUNT(node,count); MYDDAS_STATS_CON_SET_TOTAL_TIME_TRANSFERING_COUNT(node,++count); time = NULL; MYDDAS_STATS_CON_GET_LAST_TIME_TRANSFERING(node,time); MYDDAS_STATS_CON_GET_LAST_TIME_TRANSFERING_COUNT(node,count); MYDDAS_STATS_CON_SET_LAST_TIME_TRANSFERING_COUNT(node,++count); myddas_stats_move_time(diff,time); /* Measure the number of Rows returned from the server */ if (res_set != NULL) { /* With an INSERT statement, mysql_(use or store)_result() returns a NULL pointer*/ /* This is only works if we use mysql_store_result */ MyddasUInt numberRows = mysql_num_rows(res_set); MyddasUInt rows; MYDDAS_STATS_CON_GET_TOTAL_ROWS(node,rows); numberRows = numberRows + rows; MYDDAS_STATS_CON_SET_TOTAL_ROWS(node,numberRows); MYDDAS_STATS_CON_GET_TOTAL_ROWS_COUNT(node,count); MYDDAS_STATS_CON_SET_TOTAL_ROWS_COUNT(node,++count); /* Calculate the ammount of data sent by the server */ MyddasUInt total,number_fields = mysql_num_fields(res_set); MYSQL_ROW row; MyddasULInt i; total=0; while ((row = mysql_fetch_row(res_set)) != NULL){ mysql_field_seek(res_set,0); for(i=0;i TypesList */ static Int c_db_my_get_attributes_types(void) { Term arg_relation = Deref(ARG1); Term arg_conn = Deref(ARG2); Term arg_types_list = Deref(ARG3); char *relation = AtomName(AtomOfTerm(arg_relation)); MYSQL *conn = (MYSQL *) IntegerOfTerm(arg_conn); char sql[256]; MYSQL_RES *res_set; MYSQL_ROW row; Term head, list; sprintf(sql,"DESCRIBE `%s`",relation); Int length = strlen(sql); /* executar a query SQL */ if (mysql_real_query(conn, sql, length) != 0) { #ifdef DEBUG printf("Erro na query! %s\n",sql); #endif return FALSE; } /* guardar os tuplos do lado do cliente */ if ((res_set = mysql_store_result(conn)) == NULL) { #ifdef DEBUG printf("Query vazia!\n"); #endif return FALSE; } list = arg_types_list; while ((row = mysql_fetch_row(res_set)) != NULL) { head = HeadOfTerm(list); Yap_unify(head, MkAtomTerm(Yap_LookupAtom(row[0]))); list = TailOfTerm(list); head = HeadOfTerm(list); list = TailOfTerm(list); if (strncmp(row[1], "smallint",8) == 0 || strncmp(row[1],"int",3) == 0 || strncmp(row[1], "mediumint",9) == 0 || strncmp(row[1], "tinyint",7) == 0 || strncmp(row[1], "bigint",6) == 0 || strcmp(row[1], "year") == 0) Yap_unify(head, MkAtomTerm(Yap_LookupAtom("integer"))); else if (strcmp(row[1], "float") == 0 || strncmp(row[1], "double",6) == 0 || strcmp(row[1], "real") == 0) Yap_unify(head, MkAtomTerm(Yap_LookupAtom("real"))); else Yap_unify(head, MkAtomTerm(Yap_LookupAtom("string"))); } mysql_free_result(res_set); return TRUE; } /* db_disconnect */ static Int c_db_my_disconnect(void) { Term arg_conn = Deref(ARG1); MYSQL *conn = (MYSQL *) IntegerOfTerm(arg_conn); if ((myddas_util_search_connection(conn)) != NULL) { myddas_util_delete_connection(conn); mysql_close(conn); return TRUE; } else { return FALSE; } } /* db_table_write: Result Set */ static Int c_db_my_table_write(void) { Term arg_res_set = Deref(ARG1); MYSQL_RES *res_set = (MYSQL_RES *) IntegerOfTerm(arg_res_set); myddas_util_table_write(res_set); mysql_free_result(res_set); return TRUE; } static Int c_db_my_row_cut(void) { MYSQL_RES *mysql_res=NULL; mysql_res = (MYSQL_RES *) IntegerOfTerm(EXTRA_CBACK_CUT_ARG(Term,1)); mysql_free_result(mysql_res); return TRUE; } /* db_row: ResultSet x Arity_ListOfArgs x ListOfArgs -> */ static Int c_db_my_row(void) { #ifdef MYDDAS_STATS /* Measure time used by the */ /* c_db_my_row function */ MYDDAS_STATS_TIME start,end,total_time,diff; MyddasULInt count = 0; start = myddas_stats_walltime(); #endif Term arg_result_set = Deref(ARG1); Term arg_arity = Deref(ARG2); Term arg_list_args = Deref(ARG3); MYSQL_RES *res_set = (MYSQL_RES *) IntegerOfTerm(arg_result_set); EXTRA_CBACK_ARG(3,1)=(CELL) MkIntegerTerm((Int)res_set); MYSQL_ROW row; MYSQL_FIELD *field; Term head, list, null_atom[1]; Int i, arity; arity = IntegerOfTerm(arg_arity); while(TRUE) { if ((row = mysql_fetch_row(res_set)) != NULL) { mysql_field_seek(res_set,0); list = arg_list_args; for (i = 0; i < arity; i++) { /* Aqui serão feitas as conversões de tipos de dados */ field = mysql_fetch_field(res_set); head = HeadOfTerm(list); list = TailOfTerm(list); if (row[i] == NULL) { null_atom[0] = MkIntegerTerm(null_id++); if (!Yap_unify(head, Yap_MkApplTerm(Yap_MkFunctor(Yap_LookupAtom("null"),1),1,null_atom))) continue; } else { if (IS_SQL_INT(field->type)) { if (!Yap_unify(head, MkIntegerTerm(atoi(row[i])))) continue; } else if (IS_SQL_FLOAT(field->type)) { if (!Yap_unify(head, MkFloatTerm(atof(row[i])))) continue; } else { if (!Yap_unify(head, MkAtomTerm(Yap_LookupAtom(row[i])))) continue; } } } #ifdef MYDDAS_STATS end = myddas_stats_walltime(); MYDDAS_STATS_INITIALIZE_TIME_STRUCT(diff,time_copy); myddas_stats_subtract_time(diff,end,start); diff = myddas_stats_time_copy_to_final(diff); MYDDAS_FREE(end,struct myddas_stats_time_struct); MYDDAS_FREE(start,struct myddas_stats_time_struct); MYDDAS_STATS_GET_DB_ROW_FUNCTION(total_time); myddas_stats_add_time(total_time,diff,total_time); MYDDAS_STATS_GET_DB_ROW_FUNCTION_COUNT(count); MYDDAS_STATS_SET_DB_ROW_FUNCTION_COUNT(++count); MYDDAS_FREE(diff,struct myddas_stats_time_struct); #endif /* MYDDAS_STATS */ return TRUE; } else { mysql_free_result(res_set); #ifdef MYDDAS_STATS end = myddas_stats_walltime(); MYDDAS_STATS_INITIALIZE_TIME_STRUCT(diff,time_copy); myddas_stats_subtract_time(diff,end,start); diff = myddas_stats_time_copy_to_final(diff); MYDDAS_FREE(end,struct myddas_stats_time_struct); MYDDAS_FREE(start,struct myddas_stats_time_struct); MYDDAS_STATS_GET_DB_ROW_FUNCTION(total_time); myddas_stats_add_time(total_time,diff,total_time); MYDDAS_STATS_GET_DB_ROW_FUNCTION_COUNT(count); MYDDAS_STATS_SET_DB_ROW_FUNCTION_COUNT(++count); MYDDAS_FREE(diff,struct myddas_stats_time_struct); #endif /* MYDDAS_STATS */ cut_fail(); /* This macro already does a return FALSE */ } } } static Int c_db_my_get_fields_properties(void) { Term nome_relacao = Deref(ARG1); Term arg_conn = Deref(ARG2); Term fields_properties_list = Deref(ARG3); Term head, list; char *relacao = AtomName(AtomOfTerm(nome_relacao)); char sql[256]; Int num_fields,i; MYSQL_FIELD *fields; MYSQL_RES *res_set; MYSQL *conn = (MYSQL *) (IntegerOfTerm(arg_conn)); /* LIMIT 0 -> We only need the meta information about the fields to know their properties, we don't need the results of the query*/ sprintf (sql,"SELECT * FROM `%s` LIMIT 0",relacao); Int length=strlen(sql); /* executar a query SQL */ if (mysql_real_query(conn, sql, length) != 0) { #ifdef DEBUG printf("Erro na query! %s\n",sql); #endif return FALSE; } Functor functor = Yap_MkFunctor(Yap_LookupAtom("property"),4); Term properties[4]; /* guardar os tuplos do lado do cliente */ /* nao precisamos do resultado, mas apenas no res_set */ /* para obter a informação através do mysql_fetch_fields*/ res_set = mysql_store_result(conn); num_fields = mysql_num_fields(res_set); fields = mysql_fetch_fields(res_set); list = fields_properties_list; for (i=0;idb)))) return FALSE; return TRUE; } static Int c_db_my_change_database(void) { Term arg_con = Deref(ARG1); Term arg_database = Deref(ARG2); MYSQL *con = (MYSQL *) (IntegerOfTerm(arg_con)); char *database = AtomName(AtomOfTerm(arg_database)); if (mysql_select_db(con,database)!=0) return FALSE; return TRUE; } #endif /* MYDDAS_MYSQL */