[gnome-db] Interbase Provider

[gonzalo <godiard ciudad com ar>]

I am have trying to make work the interbase provider, with the actual
version of
Interbase (6.0). Is work in progress, and need help... Any volunters?
Send attached gda-interbase-connection.c with the following
improvements:
* Now connect to Interbase!!! (previous version show error -902 and not
work).
The dsn is only the path/file of the base (Ex: /home/bases/prueba.gdb)
not FILE=.. or
PATH=.. (How must be?)
* Use the user name and password for connect with the base (default for
Interbase is user:SYSDBA,
  passwd:masterkey)
* Display error messages more descriptives.
* Try to read the schema of the base, but not work.
I have a problem with gda-interbase-command or gda-interbase-recordset

Gonzalo.


P.D.: For download Interbase (a good base, now open source):
http://www.borland.com/devsupport/interbase/opensource/
P.D.2: gda-interbase.h have only minor changes.

/* GNOME DB Interbase Provider
 * 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.
 */

#if !defined(__gda_interbase_h__)
#  define __gda_interbase_h__

#if defined(HAVE_CONFIG_H)
#  include <config.h>
#endif

#include <gda-server.h>
#include <ibase.h>

#ifdef ENABLE_NLS
#  include <libintl.h>
#  define _(String) gettext (String)
#  define N_(String) (String)
#else
/* Stubs that do something close enough.  */
#  define textdomain(String)
#  define gettext(String) (String)
#  define dgettext(Domain,Message) (Message)
#  define dcgettext(Domain,Message,Type) (Message)
#  define bindtextdomain(Domain,Directory)
#  define _(String) (String)
#  define N_(String) (String)
#endif

/*
 * Per-object specific structures
 */
typedef struct
{
	isc_db_handle db;
	isc_tr_handle trans;
	ISC_STATUS status[20];
}
INTERBASE_Connection;

typedef isc_stmt_handle INTERBASE_Command;
typedef struct
{
	INTERBASE_Command ib_cmd;
	XSQLDA *sqlda;
}
INTERBASE_Recordset;

/*
 * Server implementation prototypes
 */
gboolean gda_interbase_connection_new (GdaServerConnection * cnc);
gint gda_interbase_connection_open (GdaServerConnection * cnc,
				    const gchar * dsn,
				    const gchar * user,
				    const gchar * password);
void gda_interbase_connection_close (GdaServerConnection * cnc);
gint gda_interbase_connection_begin_transaction (GdaServerConnection * cnc);
gint gda_interbase_connection_commit_transaction (GdaServerConnection * cnc);
gint gda_interbase_connection_rollback_transaction (GdaServerConnection *
						    cnc);
GdaServerRecordset *gda_interbase_connection_open_schema (GdaServerConnection
							  * cnc,
							  GdaError *
							  error,
							  GDA_Connection_QType
							  t,
							  GDA_Connection_Constraint
							  * constraints,
							  gint length);
glong gda_interbase_connection_modify_schema (GdaServerConnection * cnc,
					      GDA_Connection_QType t,
					      GDA_Connection_Constraint *
					      constraints, gint length);
gint gda_interbase_connection_start_logging (GdaServerConnection * cnc,
					     const gchar * filename);
gint gda_interbase_connection_stop_logging (GdaServerConnection * cnc);
gchar *gda_interbase_connection_create_table (GdaServerConnection * cnc,
					      GDA_RowAttributes * columns);
gboolean gda_interbase_connection_supports (GdaServerConnection * cnc,
					    GDA_Connection_Feature feature);
GDA_ValueType gda_interbase_connection_get_gda_type (GdaServerConnection *
						     cnc, gulong sql_type);
gshort gda_interbase_connection_get_c_type (GdaServerConnection * cnc,
					    GDA_ValueType type);
gchar *gda_interbase_connection_sql2xml (GdaServerConnection * cnc,
					 const gchar * sql);
gchar *gda_interbase_connection_xml2sql (GdaServerConnection * cnc,
					 const gchar * xml);
void gda_interbase_connection_free (GdaServerConnection * cnc);

gboolean gda_interbase_command_new (GdaServerCommand * cmd);
GdaServerRecordset *gda_interbase_command_execute (GdaServerCommand * cmd,
						   GdaError * error,
						   const GDA_CmdParameterSeq *
						   params, gulong * affected,
						   gulong options);
void gda_interbase_command_free (GdaServerCommand * cmd);

gboolean gda_interbase_recordset_new (GdaServerRecordset * recset);
gint gda_interbase_recordset_move_next (GdaServerRecordset * recset);
gint gda_interbase_recordset_move_prev (GdaServerRecordset * recset);
gint gda_interbase_recordset_close (GdaServerRecordset * recset);
void gda_interbase_recordset_free (GdaServerRecordset * recset);

void gda_interbase_error_make (GdaError * error,
			       GdaServerRecordset * recset,
			       GdaServerConnection * cnc, gchar * where);

#endif

/* GNOME DB Interbase Provider
 * 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-interbase.h"

gboolean
gda_interbase_connection_new (GdaServerConnection * cnc)
{
	INTERBASE_Connection *ib_cnc;

	g_return_val_if_fail (cnc != NULL, FALSE);

	/* FIXME: here it core dumps in the second connection being created */
	ib_cnc = g_new0 (INTERBASE_Connection, 1);
	ib_cnc->db = NULL;
	ib_cnc->trans = NULL;
	gda_server_connection_set_user_data (cnc, (gpointer) ib_cnc);
	return TRUE;
}

gint
gda_interbase_connection_open (GdaServerConnection * cnc,
			       const gchar * dsn,
			       const gchar * user, const gchar * password)
{
	INTERBASE_Connection *ib_cnc;
	GdaError *error;
	char dpb_buffer[256], *dpb;
	short dpb_length;
	
	g_return_val_if_fail (cnc != NULL, -1);

	ib_cnc = (INTERBASE_Connection *)
		gda_server_connection_get_user_data (cnc);

	ib_cnc->db = 0L;
	dpb = dpb_buffer;
	*dpb++ = isc_dpb_version1;
	dpb_length = dpb - dpb_buffer;
	dpb = dpb_buffer;

	isc_expand_dpb(&dpb,&dpb_length,
					isc_dpb_user_name,user,
					isc_dpb_password, password,
					NULL);

	if (ib_cnc) {
		if (!isc_attach_database
		    (ib_cnc->status, strlen(dsn), (char *)dsn, &ib_cnc->db, dpb_length, dpb)) {
			return 0;
		}

		/* return error to client */
		
		error = gda_error_new ();
		gda_server_error_make (error, 0, cnc, __PRETTY_FUNCTION__);
	}
	return -1;
}

void
gda_interbase_connection_close (GdaServerConnection * cnc)
{
	INTERBASE_Connection *ib_cnc;

	g_return_if_fail (cnc != NULL);

	ib_cnc = (INTERBASE_Connection *)
		gda_server_connection_get_user_data (cnc);
	if (ib_cnc) {
		isc_detach_database (ib_cnc->status, &ib_cnc->db);
		g_free ((gpointer) ib_cnc);
	}
}

gint
gda_interbase_connection_begin_transaction (GdaServerConnection * cnc)
{
	INTERBASE_Connection *ib_cnc;

	g_return_val_if_fail (cnc != NULL, -1);

	ib_cnc = (INTERBASE_Connection *)
		gda_server_connection_get_user_data (cnc);
	if (ib_cnc) {
		if (!ib_cnc->trans) {
			if (isc_start_transaction
			    (ib_cnc->status, &ib_cnc->trans, 1, &ib_cnc->db,
			     0, NULL)) {
				gda_server_error_make (gda_error_new (), 0,
						       cnc,
						       __PRETTY_FUNCTION__);
				return -1;
			}
		}
		return 0;
	}
	return -1;
}

gint
gda_interbase_connection_commit_transaction (GdaServerConnection * cnc)
{
	INTERBASE_Connection *ib_cnc;

	g_return_val_if_fail (cnc != NULL, -1);

	ib_cnc = (INTERBASE_Connection *)
		gda_server_connection_get_user_data (cnc);
	if (ib_cnc) {
		if (ib_cnc->trans) {
			if (isc_commit_transaction
			    (ib_cnc->status, &ib_cnc->trans) == 0)
				return 0;
			else
				gda_server_error_make (gda_error_new (), 0,
						       cnc,
						       __PRETTY_FUNCTION__);
		}
		else
			return 0;
	}
	return -1;
}

gint
gda_interbase_connection_rollback_transaction (GdaServerConnection * cnc)
{
	INTERBASE_Connection *ib_cnc;

	g_return_val_if_fail (cnc != NULL, -1);

	ib_cnc = (INTERBASE_Connection *)
		gda_server_connection_get_user_data (cnc);
	if (ib_cnc) {
		if (ib_cnc->trans) {
			if (isc_rollback_transaction
			    (ib_cnc->status, &ib_cnc->trans) == 0)
				return 0;
			else
				gda_server_error_make (gda_error_new (), 0,
						       cnc,
						       __PRETTY_FUNCTION__);
		}
		else
			return 0;
	}
	return -1;
}

GdaServerRecordset *
gda_interbase_connection_open_schema (GdaServerConnection * cnc,
				      GdaError * error,
				      GDA_Connection_QType t,
				      GDA_Connection_Constraint * constraints,
				      gint length)
{
	GdaServerCommand *cmd = NULL;
	gchar *query = 		
			"SELECT "
			"A.RDB$RELATION_NAME Name, "
			"A.RDB$DESCRIPTION Comments "
			"FROM "
			"RDB$RELATIONS A "
			"WHERE (A.RDB$VIEW_SOURCE IS NULL)";


	cmd = gda_server_command_new (cnc);
	gda_server_command_set_text (cmd, query);

	if (!error)
		error = gda_error_new ();

	/* execute the command */
	return gda_server_command_execute (cmd, error, NULL, NULL, 0);

//	return NULL;
}

glong
gda_interbase_connection_modify_schema (GdaServerConnection * cnc,
					GDA_Connection_QType t,
					GDA_Connection_Constraint *
					constraints, gint length)
{
	return -1;
}

gint
gda_interbase_connection_start_logging (GdaServerConnection * cnc,
					const gchar * filename)
{
	return -1;
}

gint
gda_interbase_connection_stop_logging (GdaServerConnection * cnc)
{
	return -1;
}

gchar *
gda_interbase_connection_create_table (GdaServerConnection * cnc,
				       GDA_RowAttributes * columns)
{
	return NULL;
}

gboolean
gda_interbase_connection_supports (GdaServerConnection * cnc,
				   GDA_Connection_Feature feature)
{
	g_return_val_if_fail (cnc != NULL, FALSE);

	if (feature == GDA_Connection_FEATURE_TRANSACTIONS)
		return (TRUE);
	return FALSE;		/* not supported or know nothing about it */
}

GDA_ValueType
gda_interbase_connection_get_gda_type (GdaServerConnection * cnc,
				       gulong sql_type)
{
	g_return_val_if_fail (cnc != NULL, GDA_TypeNull);

	switch (sql_type) {
	case SQL_TEXT:
	case SQL_VARYING:
		return GDA_TypeLongvarchar;
	case SQL_SHORT:
		return GDA_TypeSmallint;
	case SQL_LONG:
		return GDA_TypeInteger;
	case SQL_INT64:
		return GDA_TypeBigint;
	case SQL_FLOAT:
		return GDA_TypeSingle;
	case SQL_DOUBLE:
		return GDA_TypeDouble;
	case SQL_TIMESTAMP:
		return GDA_TypeDbTimestamp;
	case SQL_TYPE_DATE:
		return GDA_TypeDbDate;
	case SQL_TYPE_TIME:
		return GDA_TypeDbTime;
	case SQL_BLOB:
	case SQL_ARRAY:
		return GDA_TypeBinary;
	}
	return GDA_TypeNull;
}

gshort
gda_interbase_connection_get_c_type (GdaServerConnection * cnc,
				     GDA_ValueType type)
{
	g_return_val_if_fail (cnc != NULL, -1);

	//switch (type)
	//  {
	//  }
	return -1;
}

gchar *
gda_interbase_connection_sql2xml (GdaServerConnection * cnc,
				  const gchar * sql)
{
	return NULL;
}

gchar *
gda_interbase_connection_xml2sql (GdaServerConnection * cnc,
				  const gchar * xml)
{
	return NULL;
}

void
gda_interbase_connection_free (GdaServerConnection * cnc)
{
	INTERBASE_Connection *ib_cnc;

	g_return_if_fail (cnc != NULL);

	ib_cnc = (INTERBASE_Connection *)
		gda_server_connection_get_user_data (cnc);
	if (ib_cnc) {
		g_free ((gpointer) ib_cnc);
	}
}

void
gda_interbase_error_make (GdaError * error,
			  GdaServerRecordset * recset,
			  GdaServerConnection * cnc, gchar * where)
{
	gchar *err_msg;		/* FIXME: retireve error message from server */
	INTERBASE_Connection *ib_cnc;

	long * pvector;
	char msg[512]; 

	ib_cnc = (INTERBASE_Connection *)
		gda_server_connection_get_user_data (cnc);
	if (ib_cnc) {

		pvector =ib_cnc->status; 
		isc_interprete(msg,&pvector);

		err_msg =
			g_strdup_printf (_("Error code %ld (%s)"),
					 isc_sqlcode (ib_cnc->status),msg);


		gda_log_error (_("error '%s' at %s"), err_msg, where);

		gda_error_set_description (error, err_msg);
		gda_error_set_number (error, isc_sqlcode (ib_cnc->status));
		gda_error_set_source (error, "[gda-interbase]");
		gda_error_set_help_url (error, "http://www.interbase.org/";);
		gda_error_set_help_context (error, _("Not available"));
		gda_error_set_sqlstate (error, _("error"));
		gda_error_set_native (error, err_msg);

		g_free ((gpointer) err_msg);
//		isc_print_sqlerror (isc_sqlcode (ib_cnc), ib_cnc->status);
	}
}