/* GNOME DB MySQL Provider
 * Copyright (C) 1998 Michael Lausch
 * Copyright (C) 2000 Rodrigo Moya
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Library General Public
 * License as published by the Free Software Foundation; either
 * version 2 of the License, or (at your option) any later version.
 *
 * This library 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
 * Library General Public License for more details.
 *
 * You should have received a copy of the GNU Library General Public
 * License along with this library; if not, write to the Free
 * Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
 */

#include "gda-mysql.h"

static void
fill_field_values (GdaServerRecordset *recset, MYSQL_Recordset *mysql_recset)
{
  gint   rowlength;
  gint   fieldidx;
  GList* node;

  g_return_if_fail(recset != NULL);
  g_return_if_fail(mysql_recset != NULL);

  /* call fix_fields callback */
  if (mysql_recset->fix_fields)
    {
      mysql_recset->array = mysql_recset->fix_fields(mysql_recset, mysql_recset->array);
    }
  mysql_recset->lengths = mysql_fetch_lengths(mysql_recset->mysql_res);

  rowlength = mysql_num_fields(mysql_recset->mysql_res);
  for (fieldidx = 0; fieldidx < rowlength; fieldidx++)
    {
      node = g_list_nth(gda_server_recordset_get_fields(recset), fieldidx);
      if (node)
	{
	  if (mysql_recset->array[fieldidx])
	    {
	      GdaServerField* field = (GdaServerField *) node->data;
	      switch (gda_server_field_get_sql_type(field))
		{
		case FIELD_TYPE_TINY :
		case FIELD_TYPE_SHORT :
		  gda_server_field_set_smallint(field, atoi(mysql_recset->array[fieldidx]));
		  break;
		case FIELD_TYPE_LONG :
		  gda_server_field_set_integer(field, atoi(mysql_recset->array[fieldidx]));
		  break;
		case FIELD_TYPE_DECIMAL :
		case FIELD_TYPE_FLOAT :
		  gda_server_field_set_single(field, atof(mysql_recset->array[fieldidx]));
		  break;
		case FIELD_TYPE_DOUBLE :
		  gda_server_field_set_double(field, atof(mysql_recset->array[fieldidx]));
		  break;
		case FIELD_TYPE_STRING :
		default :
		  gda_server_field_set_varchar(field, mysql_recset->array[fieldidx]);
		  break;
		}
	    }
	  else /* NULL value */
	    {
	      gda_server_field_set_actual_length((GdaServerField *) node->data, 0);
	    }
	}
    }
}

gboolean
gda_mysql_recordset_new (GdaServerRecordset *recset)
{
  MYSQL_Recordset* mysql_recset;

  mysql_recset = g_new0(MYSQL_Recordset, 1);
  gda_server_recordset_set_user_data(recset, (gpointer) mysql_recset);

  return TRUE;
}

gint
gda_mysql_recordset_move_next (GdaServerRecordset *recset)
{
  MYSQL_Recordset* mysql_recset;

  g_return_val_if_fail(recset != NULL, -1);

  mysql_recset = (MYSQL_Recordset *) gda_server_recordset_get_user_data(recset);
  if (mysql_recset)
    {
      mysql_recset->array = mysql_fetch_row(mysql_recset->mysql_res);
      if (mysql_recset->array)
	{
	  fill_field_values(recset, mysql_recset);
	  return 0;
	}
      else /* end-of-file */
	{
	  gda_server_recordset_set_at_begin(recset, FALSE);
	  gda_server_recordset_set_at_end(recset, TRUE);
	  return 1;
	}
    }
  return -1;
}

gint
gda_mysql_recordset_move_prev (GdaServerRecordset *recset)
{
  return -1;
}

gint
gda_mysql_recordset_close (GdaServerRecordset *recset)
{
  MYSQL_Recordset* mysql_recset;

  g_return_val_if_fail(recset != NULL, -1);

  mysql_recset = (MYSQL_Recordset *) gda_server_recordset_get_user_data(recset);
  if (mysql_recset)
    {
      mysql_free_result(mysql_recset->mysql_res);
      mysql_recset->mysql_res = NULL;
      return 0;
    }
  return -1;
}

void
gda_mysql_recordset_free (GdaServerRecordset *recset)
{
  MYSQL_Recordset* mysql_recset;

  g_return_if_fail(recset != NULL);

  mysql_recset = (MYSQL_Recordset *) gda_server_recordset_get_user_data(recset);
  if (mysql_recset)
    {
      g_free((gpointer) mysql_recset);
      gda_server_recordset_set_user_data(recset, NULL);
    }
}