/*==========================================
 * Allow user to execute SQL queries [Zarin]
 *------------------------------------------
 */
int buildin_query_sql(struct script_state *st)
{
	char *name = NULL;
    char *query;
	int num, i = 0,j, nb_rows;
	struct { char * dst_var_name; char type; } row[32];
	TBL_PC *sd = (st->rid)? script_rid2sd(st) : NULL;

	query = conv_str(st,& (st->stack->stack_data[st->start+2]));
	strcpy(tmp_sql, query);
    
    // ----------
    // Connect
    
    //DB connection initialized
	mysql_init(&mysql_handle);
	printf("Connect MySQL server");
	printf("...\n");

	if(!mysql_real_connect(&mysql_handle, '127.0.0.1', 'aurora', 'aurora',
		'aurora' ,3306, (char *)NULL, 0)
	) {
		printf("%s\n",mysql_error(&mysql_handle));
		exit(1);
	} else {
		printf ("Connect Success! (MySQL Server)\n");
	}
    
    // ----------
    
	if(mysql_query(&mysql_handle,tmp_sql)){
        // Close connection
        mysql_close(&mysql_handle);
        //mysql_handle = NULL;
        
		//ShowSQL("DB error - %s\n",mysql_error(&mmysql_handle));
		//ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql);
		push_val(st->stack,C_INT,0);
		return 1;
	}

	// If some data was returned
	if((sql_res = mysql_store_result(&mysql_handle))){
		// Count the number of rows to store
		nb_rows = mysql_num_fields(sql_res);

		// Can't store more row than variable
		if (nb_rows > st->end - (st->start+3))
			nb_rows = st->end - (st->start+3);

		if (!nb_rows)
		{
            // Close connection
            mysql_close(&mysql_handle);
            //mysql_handle = NULL;
            
			push_val(st->stack,C_INT,0);
			return 0; // Nothing to store
		}
		if (nb_rows > 32)
		{
            // Close connection
            mysql_close(&mysql_handle);
            //mysql_handle = NULL;
            
			//ShowWarning("buildin_query_sql: too many rows!\n");
			push_val(st->stack,C_INT,0);
			return 1;
		}

		memset(row, 0, sizeof(row));
		// Verify argument types
		for(j=0; j < nb_rows; j++)
		{
			//if(!data_isreference(conv_str(st,& (st->stack->stack_data[st->start+3+j])))){
			//	//ShowWarning("buildin_query_sql: Parameter %d is not a variable!\n", j);
			//	push_val(st->stack,C_INT,0);
			//	return 0;
			//} else {
				// Store type of variable (string = 0/int = 1)
				num=st->stack->stack_data[st->start+3+j].u.num;
				name=(char *)(str_buf+str_data[num&0x00ffffff].str);
				if(name[strlen(name)-1] != '$') {
					row[j].type = 1;
				}
				row[j].dst_var_name = name;

			//}
		}
		// Store data
		while(i<128 && (sql_row = mysql_fetch_row(sql_res))){
			for(j=0; j < nb_rows; j++)
			{
				if (row[j].type == 1)
                    push_val(st->stack,C_INT,(void *)atoi(sql_row[j]));
					//setd_sub(st,sd, row[j].dst_var_name, i, (void *)atoi(sql_row[j]),script_getref(st,3+j));
				else
                    push_val(st->stack,C_CONSTSTR,(void *)sql_row[j]);
					//setd_sub(st,sd, row[j].dst_var_name, i, (void *)sql_row[j],script_getref(st,3+j));
			}
			i++;
		}
		// Free data
		mysql_free_result(sql_res);
	}
	push_val(st->stack,C_INT,i);

    // Close connection
    mysql_close(&mysql_handle);
    //mysql_handle = NULL;
    
	return 0;
}