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

#define MAX_BUFF 2048
#define MAX_TOP 10

MYSQL_RES *global_res;

struct filme
{
	int id,gen_id,an,nr_voturi;
	char denumire[100],regizor[100];
} *filme[100];


void sendResponse(char *resp) {
	printf("Resp: %s\n", resp);
}

void executeCommand(char* command) {

	char resp[MAX_BUFF];
	int i;

	if (!strncmp(command,"viewtop",7))
	{
		viewTop(command+8);

		for(i = 0; i < MAX_TOP; i++) {
			sprintf(resp, "id: %d, nume: %s", filme[i]->id, filme[i]->denumire);
		}
	}
	/*if (!strncmp(command,"getgens",7))
	{
		getgens();
	}
	if (!strncmp(command,"votemovie",7))
	{
		getgens();
	}*/

}


void viewTop(char* gen)
{
   MYSQL_ROW row;

   int k = 0;

   char query[] = "select id,denumire from Filme";
   executeQuery(query);

	while ((row = mysql_fetch_row(global_res)) != NULL) {

		filme[k]->id = row[0];
		strcpy(filme[k]->denumire,row[1]);

		k++;
	}
}

void executeQuery(char* query)
{
   MYSQL *conn;
   MYSQL_ROW row;

   char *server = "localhost";
   char *user = "root";
   char *password = "irina"; /* set me first */
   char *database = "Movies";

   conn = mysql_init(NULL);

   /* Connect to database */
   if (!mysql_real_connect(conn, server,
         user, password, database, 0, NULL, 0)) {
      fprintf(stderr, "%s\n", mysql_error(conn));
      exit(1);
   }

   /* send SQL query */
   if (mysql_query(conn, query)) {
      fprintf(stderr, "%s\n", mysql_error(conn));
      exit(1);
   }

   global_res = mysql_use_result(conn);
}


int main ()
{
	char response[MAX_BUFF];

	char comanda[] = "getgens";

	//response = executeCommand(comanda);
	executeCommand(comanda);

	//sendResponse(response);


	return 0;
}