root/trunk/src/mysql_mgmt.c @ 32

/*
 * File: mysql_mgmt.c
 * 
 * Authors: ANDREU François-Xavier 
 *
 * Copyright (C) 2005 GIP RENATER 
 */

/*  This file is part of renetcol. 
 *
 *  renetcol is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  renetcol is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with renetcol; if not, write to the Free Software
 *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
 */

#include "mysql_mgmt.h"

/*
 * get_dbpass
 */
char *get_dbpass()
{
  char * pass;
  pass = getpass("DB password : ");
  return pass;
}


/*
 * init_connection
 */
MYSQL *init_connection ()
{
  MYSQL *my_connection;

  if (!(my_connection = mysql_init (NULL)))
    {                           /*FIXME: free after*/
      fprintf (stderr, "ERROR IN mysql_init\n");
      exit (1);
    }
  if (!mysql_real_connect (my_connection, DB_HOST, DB_USER, get_dbpass(),
                           DB_NAME, 0, NULL, 0))
    {
      fprintf (stderr, "Failed to connect to database: ERROR: %s\n",
               mysql_error (my_connection));
      exit (1);
    }
  fprintf (stderr, "infos: %s\n", mysql_get_host_info (my_connection));
  return my_connection;
}

/*
 * close_connection
 */
void close_connection (MYSQL * myc)
{
  mysql_close (myc);
}


/*
 * get_info_bd
 *
 */
void
get_info_bd (MYSQL * myc)
{
  MYSQL *my_connection = myc;
  MYSQL_RES *my_res;
  MYSQL_ROW my_row;
  unsigned int num_fields, i;

  if (!(my_res = mysql_list_tables (my_connection, NULL)))
    {
      fprintf (stderr, "Failed to list tables: ERROR: %s\n",
               mysql_error (my_connection));
      exit (1);
    }
  num_fields = mysql_num_fields (my_res);
  while ((my_row = mysql_fetch_row (my_res)))
    {
      unsigned long *lengths;
      lengths = mysql_fetch_lengths (my_res);
      for (i = 0; i < num_fields; i++)
        {
          fprintf (stderr, " %s ", my_row[i]);
        }
      fprintf (stderr, "\n");
    }
  mysql_free_result (my_res);

  if (mysql_real_query
      (my_connection, REQ_OUTPUT_TYPE, strlen (REQ_OUTPUT_TYPE)))
    {
      fprintf (stderr, "Failed to query OUTPUT_TYPE table: ERROR: %s\n",
               mysql_error (my_connection));
      exit (1);
    }
  my_res = mysql_store_result (my_connection);
  if (my_res)
    {
      fprintf (stderr, "RESULT: %d rows\n",
               (int)mysql_affected_rows (my_connection));
      num_fields = mysql_num_fields (my_res);
      while ((my_row = mysql_fetch_row (my_res)))
        {
          unsigned long *lengths;
          lengths = mysql_fetch_lengths (my_res);
          for (i=0; i<(num_fields); i++) {
            fprintf (stderr, " %s ", my_row[i]);
          }
          fprintf (stderr, "\n");
        }
    }
  else
    {
      if (mysql_field_count (my_connection) == 0)
        {
          /*query does not return data*/
          fprintf (stderr, "IT WAS NOT a SELECT\n");
        }
      else
        {
          fprintf (stderr, "RESULT EMPTY, ERROR: %s\n",
                   mysql_error (my_connection));
        }
    }
  mysql_free_result (my_res);
}

/*
 * get_rules
 *
 */

p_rules get_rules(MYSQL * myc, p_rules pr)
{
  MYSQL *my_connection = myc;
  MYSQL_RES *my_res;
  MYSQL_ROW my_row;
  unsigned int num_fields;
  struct tm     tm;
  
  memset (& tm, 0, sizeof (struct tm));
  if (mysql_real_query
      (my_connection, REQ_FILTRES_TABLE, strlen (REQ_FILTRES_TABLE)))
    {
      fprintf (stderr, "Failed to query FILTRES table: ERROR: %s\n",
               mysql_error (my_connection));
      exit (1);
    }
  my_res = mysql_store_result (my_connection);
  if (my_res)
    {
      fprintf (stderr, "RESULT: %d rows\n",
               mysql_affected_rows (my_connection));
      num_fields = mysql_num_fields (my_res);
      while ((my_row = mysql_fetch_row (my_res)))
        {
        }
    }
  else
    {
      if (mysql_field_count (my_connection) == 0)
        {
          /*query does not return data*/
          fprintf (stderr, "IT WAS NOT a SELECT\n");
        }
      else
        {
          fprintf (stderr, "RESULT EMPTY, ERROR: %s\n",
                   mysql_error (my_connection));
        }
    }
  mysql_free_result (my_res);
  return pr;
}


/*
 * get_fields_to_record
 *
 */
void
get_fields_to_record(MYSQL * myc, unsigned short idr)
{
  MYSQL *my_connection = myc;
  MYSQL_RES *my_res;
  MYSQL_ROW my_row;
  unsigned int num_fields, i;
  
  if (mysql_real_query
      (my_connection, REQ_FIELDS_TO_RECORD, strlen (REQ_FIELDS_TO_RECORD)))
    {
      fprintf (stderr, "Failed to query FIELDS_TO_RECORD table: ERROR: %s\n",
               mysql_error (my_connection));
      exit (1);
    }
  my_res = mysql_store_result (my_connection);
  if (my_res)
    {
      fprintf (stderr, "RESULT: %d rows\n",
               mysql_affected_rows (my_connection));
      num_fields = mysql_num_fields (my_res);
      while ((my_row = mysql_fetch_row (my_res)))
        {
          unsigned long *lengths;
          lengths = mysql_fetch_lengths (my_res);
          for (i=0; i<(num_fields); i++) {
            fprintf (stderr, " %s ", my_row[i]);
          }
          fprintf (stderr, "\n");
        }
    }
  else
    {
      if (mysql_field_count (my_connection) == 0)
        {
          /*query does not return data*/
          fprintf (stderr, "IT WAS NOT a SELECT\n");
        }
      else
        {
          fprintf (stderr, "RESULT EMPTY, ERROR: %s\n",
                   mysql_error (my_connection));
        }
    }
  mysql_free_result (my_res);
}


/*
 * get_output
 *
 */
void
get_output(MYSQL * myc, unsigned short ido, p_rules rl)
{
  MYSQL *my_connection = myc;
  MYSQL_RES *my_res;
  MYSQL_ROW my_row;
  unsigned int num_fields, i;
  
  if (mysql_real_query
      (my_connection, REQ_OUTPUT_TABLE, strlen (REQ_OUTPUT_TABLE)))
    {
      fprintf (stderr, "Failed to query OUTPUT_TABLE table: ERROR: %s\n",
               mysql_error (my_connection));
      exit (1);
    }
  my_res = mysql_store_result (my_connection);
  if (my_res)
    {
      fprintf (stderr, "RESULT: %d rows\n",
               mysql_affected_rows (my_connection));
      num_fields = mysql_num_fields (my_res);
      while ((my_row = mysql_fetch_row (my_res)))
        {
          unsigned long *lengths;
          lengths = mysql_fetch_lengths (my_res);
          for (i=0; i<(num_fields); i++) {
            fprintf (stderr, " %s ", my_row[i]);
          }
          fprintf (stderr, "\n");
        }
    }
  else
    {
      if (mysql_field_count (my_connection) == 0)
        {
          /*query does not return data*/
          fprintf (stderr, "IT WAS NOT a SELECT\n");
        }
      else
        {
          fprintf (stderr, "RESULT EMPTY, ERROR: %s\n",
                   mysql_error (my_connection));
        }
    }
  mysql_free_result (my_res);
}