[libgda: 1/7] DDL/PostgreSQL: DDL operation for PostgreSQL
- From: Daniel Espinosa Ortiz <despinosa src gnome org>
- To: commits-list gnome org
- Cc:
- Subject: [libgda: 1/7] DDL/PostgreSQL: DDL operation for PostgreSQL
- Date: Thu, 19 Mar 2020 14:56:21 +0000 (UTC)
commit 0082496dadf034cac01f963cabac429b64420f66
Author: Pavlo Solntsev <p sun fun gmail com>
Date: Fri Jan 31 14:19:08 2020 -0600
DDL/PostgreSQL: DDL operation for PostgreSQL
tests/meson.build | 24 +-
tests/test-server-operation-postgresql.c | 1004 ++++++++++++++++++++++++++++++
2 files changed, 1027 insertions(+), 1 deletion(-)
---
diff --git a/tests/meson.build b/tests/meson.build
index b649d6967..620c09d61 100644
--- a/tests/meson.build
+++ b/tests/meson.build
@@ -207,6 +207,29 @@ test('SqlRenderer', tsqlr,
]
)
+tsop = executable('test-server-operation-postgresql',
+ ['test-server-operation-postgresql.c'] ,
+ c_args: [
+ '-include',
+ meson.build_root() + '/config.h',
+ '-DCHECK_FILES="'+meson.source_root()+'"',
+ '-DTOP_BUILD_DIR="'+meson.build_root()+'"'
+ ],
+ link_with: libgda,
+ dependencies: [
+ libgda_dep,
+ inc_rooth_dep,
+ inc_sqliteh_dep
+ ],
+ install: false
+ )
+test('ServerOperationPostgreSQL', tsop,
+ env: [
+ 'GDA_TOP_SRC_DIR='+gda_top_src,
+ 'GDA_TOP_BUILD_DIR='+gda_top_build
+ ]
+ )
+
tso = executable('test-server-operation-sqlite',
['test-server-operation-sqlite.c'] ,
c_args: [
@@ -229,7 +252,6 @@ test('ServerOperationSQLite', tso,
'GDA_TOP_BUILD_DIR='+gda_top_build
]
)
-
tmp = executable('test-provider-meta',
['test-provider-meta.c'] ,
c_args: test_cargs,
diff --git a/tests/test-server-operation-postgresql.c b/tests/test-server-operation-postgresql.c
new file mode 100644
index 000000000..b5c23cecd
--- /dev/null
+++ b/tests/test-server-operation-postgresql.c
@@ -0,0 +1,1004 @@
+/* check-server-operation-postgresql.c
+ *
+ * Copyright (C) 2020 Pavlo Solntsev <p sun fun gmail com>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser 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
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, write to the
+ * Free Software Foundation, Inc., 51 Franklin St, Fifth Floor,
+ * Boston, MA 02110-1301, USA.
+ */
+
+/*
+ * Two tables will be created:
+ *
+ * Project
+ * =======================
+ * id | name
+ *
+ * Employee
+ * =======================
+ * id | name | project_id
+ *
+ * An additional column "cost" will be added via ADD_COLUMN operation to the table Project
+ *
+ * Employee table will be renamed to NewEmployee
+ *
+ */
+#include <glib.h>
+#include <glib/gi18n.h>
+#include <locale.h>
+#include <libgda/libgda.h>
+
+#define PROVIDER_NAME "PostgreSQL"
+
+typedef struct
+{
+ GdaConnection *cnc;
+ GdaServerProvider *provider;
+} TestObjectFixture;
+
+static void
+test_server_operation_start (TestObjectFixture *fixture,
+ G_GNUC_UNUSED gconstpointer user_data)
+{
+ fixture->cnc = NULL;
+ fixture->provider = NULL;
+
+ const gchar *db_string = g_getenv("POSTGRESQL_CNC_PARAMS");
+
+ if (!db_string)
+ {
+ g_print ("Please set POSTGRESQL_DBCREATE_PARAMS variable"
+ "with host,user and port (usually 5432)");
+ g_print ("Test will not be performed\n");
+ return;
+ }
+
+ fixture->cnc = gda_connection_open_from_string (PROVIDER_NAME,
+ db_string,
+ NULL,
+ GDA_CONNECTION_OPTIONS_NONE,
+ NULL);
+
+ g_assert_nonnull (fixture->cnc);
+
+ fixture->provider = gda_connection_get_provider (fixture->cnc);
+
+ g_assert_nonnull (fixture->provider);
+}
+
+static void
+test_server_operation_finish (TestObjectFixture *fixture,
+ G_GNUC_UNUSED gconstpointer user_data)
+{
+ gboolean res = gda_connection_close (fixture->cnc, NULL);
+
+ g_assert_true (res);
+}
+
+static void
+test_server_operation_operations (TestObjectFixture *fixture,
+ G_GNUC_UNUSED gconstpointer user_data)
+{
+ GdaServerOperation *op = NULL;
+
+/* CREATE_TABLE operation */
+ op = gda_server_provider_create_operation (fixture->provider,
+ fixture->cnc,
+ GDA_SERVER_OPERATION_CREATE_TABLE,
+ NULL,
+ NULL);
+
+ g_assert_nonnull (op);
+
+/* We will create two tables: Employee and Project. One table will contain foreigh key that points
+ * to the column from the second one.
+ *
+ */
+
+ gboolean res = FALSE;
+ /* Define table name */
+ res = gda_server_operation_set_value_at (op,
+ "Project",
+ NULL,
+ "/TABLE_DEF_P/TABLE_NAME");
+
+ g_assert_true (res);
+
+ /* Table will not be temporary */
+ res = gda_server_operation_set_value_at (op,
+ "FALSE",
+ NULL,
+ "/TABLE_DEF_P/TABLE_TEMP");
+
+ g_assert_true (res);
+
+ /* Create table if table doesn't exist yet */
+ res = gda_server_operation_set_value_at (op,
+ "TRUE",
+ NULL,
+ "/TABLE_DEF_P/TABLE_IFNOTEXISTS");
+ g_assert_true (res);
+
+ /* Define column id*/
+ gint column_order = 0;
+ res = gda_server_operation_set_value_at (op,
+ "id",
+ NULL,
+ "/FIELDS_A/@COLUMN_NAME/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "gint",
+ NULL,
+ "/FIELDS_A/@COLUMN_TYPE/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "TRUE",
+ NULL,
+ "/FIELDS_A/@COLUMN_NNUL/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "TRUE",
+ NULL,
+ "/FIELDS_A/@COLUMN_AUTOINC/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "TRUE",
+ NULL,
+ "/FIELDS_A/@COLUMN_UNIQUE/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "TRUE",
+ NULL,
+ "/FIELDS_A/@COLUMN_PKEY/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ /* Define column name */
+ column_order++;
+ res = gda_server_operation_set_value_at (op,
+ "name",
+ NULL,
+ "/FIELDS_A/@COLUMN_NAME/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "gchararray",
+ NULL,
+ "/FIELDS_A/@COLUMN_TYPE/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "50",
+ NULL,
+ "/FIELDS_A/@COLUMN_SIZE/%d",
+ column_order);
+
+ g_assert_true (res);
+ res = gda_server_operation_set_value_at (op,
+ "TRUE",
+ NULL,
+ "/FIELDS_A/@COLUMN_NNUL/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "FALSE",
+ NULL,
+ "/FIELDS_A/@COLUMN_AUTOINC/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "TRUE",
+ NULL,
+ "/FIELDS_A/@COLUMN_UNIQUE/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "FALSE",
+ NULL,
+ "/FIELDS_A/@COLUMN_PKEY/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "Default_name",
+ NULL,
+ "/FIELDS_A/@COLUMN_DEFAULT/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_provider_perform_operation (fixture->provider,
+ fixture->cnc,
+ op,
+ NULL);
+
+ g_assert_true (res);
+
+ g_clear_object (&op);
+
+ op = gda_server_provider_create_operation (fixture->provider,
+ fixture->cnc,
+ GDA_SERVER_OPERATION_CREATE_TABLE,
+ NULL,
+ NULL);
+
+ g_assert_nonnull (op);
+
+/* We will create two tables: Employee and Project. One table will contain foreigh key that points
+ * to the column from the second one.
+ *
+ */
+ /* Define table name */
+ res = gda_server_operation_set_value_at (op,
+ "Employee",
+ NULL,
+ "/TABLE_DEF_P/TABLE_NAME");
+
+ g_assert_true (res);
+
+ /* Table will not be temporary */
+ res = gda_server_operation_set_value_at (op,
+ "FALSE",
+ NULL,
+ "/TABLE_DEF_P/TABLE_TEMP");
+
+ g_assert_true (res);
+
+ /* Create table if table doesn't exist yet */
+ res = gda_server_operation_set_value_at (op,
+ "TRUE",
+ NULL,
+ "/TABLE_DEF_P/TABLE_IFNOTEXISTS");
+ g_assert_true (res);
+
+ /* Define column id */
+ column_order = 0;
+ res = gda_server_operation_set_value_at (op,
+ "id",
+ NULL,
+ "/FIELDS_A/@COLUMN_NAME/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "gint",
+ NULL,
+ "/FIELDS_A/@COLUMN_TYPE/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "TRUE",
+ NULL,
+ "/FIELDS_A/@COLUMN_NNUL/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "TRUE",
+ NULL,
+ "/FIELDS_A/@COLUMN_AUTOINC/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "TRUE",
+ NULL,
+ "/FIELDS_A/@COLUMN_UNIQUE/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "TRUE",
+ NULL,
+ "/FIELDS_A/@COLUMN_PKEY/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ /* Define column name */
+ column_order++;
+ res = gda_server_operation_set_value_at (op,
+ "name",
+ NULL,
+ "/FIELDS_A/@COLUMN_NAME/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "gchararray",
+ NULL,
+ "/FIELDS_A/@COLUMN_TYPE/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "50",
+ NULL,
+ "/FIELDS_A/@COLUMN_SIZE/%d",
+ column_order);
+
+ g_assert_true (res);
+ res = gda_server_operation_set_value_at (op,
+ "TRUE",
+ NULL,
+ "/FIELDS_A/@COLUMN_NNUL/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "FALSE",
+ NULL,
+ "/FIELDS_A/@COLUMN_AUTOINC/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "TRUE",
+ NULL,
+ "/FIELDS_A/@COLUMN_UNIQUE/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "FALSE",
+ NULL,
+ "/FIELDS_A/@COLUMN_PKEY/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "Default_name",
+ NULL,
+ "/FIELDS_A/@COLUMN_DEFAULT/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ /* Define column project_id */
+ column_order++;
+ res = gda_server_operation_set_value_at (op,
+ "project_id",
+ NULL,
+ "/FIELDS_A/@COLUMN_NAME/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "gint",
+ NULL,
+ "/FIELDS_A/@COLUMN_TYPE/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "TRUE",
+ NULL,
+ "/FIELDS_A/@COLUMN_NNUL/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "FALSE",
+ NULL,
+ "/FIELDS_A/@COLUMN_AUTOINC/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "FALSE",
+ NULL,
+ "/FIELDS_A/@COLUMN_UNIQUE/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "FALSE",
+ NULL,
+ "/FIELDS_A/@COLUMN_PKEY/%d",
+ column_order);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "Project",
+ NULL,
+ "/FKEY_S/%d/FKEY_REF_TABLE",
+ 0);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "RESTRICT",
+ NULL,
+ "/FKEY_S/%d/FKEY_ONDELETE",
+ 0);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "RESTRICT",
+ NULL,
+ "/FKEY_S/%d/FKEY_ONUPDATE",
+ 0);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "project_id",
+ NULL,
+ "/FKEY_S/%d/FKEY_FIELDS_A/@FK_FIELD/%d",
+ 0,0);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "id",
+ NULL,
+ "/FKEY_S/%d/FKEY_FIELDS_A/@FK_REF_PK_FIELD/%d",
+ 0,0);
+
+ g_assert_true (res);
+
+ res = gda_server_provider_perform_operation (fixture->provider,
+ fixture->cnc,
+ op,
+ NULL);
+
+ g_assert_true (res);
+ /* END of CREATE_TABLE operation */
+
+ g_clear_object (&op);
+
+ /* Start of ADD_COLUMN operation */
+ op = gda_server_provider_create_operation (fixture->provider, fixture->cnc,
+ GDA_SERVER_OPERATION_ADD_COLUMN,
+ NULL,
+ NULL);
+
+ g_assert_nonnull (op);
+
+ res = gda_server_operation_set_value_at (op,
+ "Project",
+ NULL,
+ "/COLUMN_DEF_P/TABLE_NAME");
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "cost",
+ NULL,
+ "/COLUMN_DEF_P/COLUMN_NAME");
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "gfloat",
+ NULL,
+ "/COLUMN_DEF_P/COLUMN_TYPE");
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "5",
+ NULL,
+ "/COLUMN_DEF_P/COLUMN_SIZE");
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "2",
+ NULL,
+ "/COLUMN_DEF_P/COLUMN_SCALE");
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "FALSE",
+ NULL,
+ "/COLUMN_DEF_P/COLUMN_NNUL");
+
+ g_assert_true (res);
+
+ res = gda_server_provider_perform_operation (fixture->provider,
+ fixture->cnc,
+ op,
+ NULL);
+
+ g_assert_true (res);
+
+ g_clear_object (&op);
+
+ /* START RENAME_TABLE OPERATION */
+ op = gda_server_provider_create_operation (fixture->provider, fixture->cnc,
+ GDA_SERVER_OPERATION_RENAME_TABLE,
+ NULL,
+ NULL);
+
+ g_assert_true (op);
+
+ res = gda_server_operation_set_value_at (op,
+ "Employee",
+ NULL,
+ "/TABLE_DESC_P/TABLE_NAME");
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "NewEmployee",
+ NULL,
+ "/TABLE_DESC_P/TABLE_NEW_NAME");
+
+ g_assert_true (res);
+
+ res = gda_server_provider_perform_operation (fixture->provider,
+ fixture->cnc,
+ op,
+ NULL);
+
+ g_assert_true (res);
+
+ /* END RENAME_TABLE OPERATION */
+ g_clear_object (&op);
+
+ /* START CREATE_VIEW OPERATION */
+ op = gda_server_provider_create_operation (fixture->provider,
+ fixture->cnc,
+ GDA_SERVER_OPERATION_CREATE_VIEW,
+ NULL,
+ NULL);
+
+ g_assert_nonnull (op);
+
+ res = gda_server_operation_set_value_at (op,
+ "MyView",
+ NULL,
+ "/VIEW_DEF_P/VIEW_NAME");
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "FALSE",
+ NULL,
+ "/VIEW_DEF_P/VIEW_TEMP");
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "TRUE",
+ NULL,
+ "/VIEW_DEF_P/VIEW_IFNOTEXISTS");
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "SELECT name, project_id FROM NewEmployee",
+ NULL,
+ "/VIEW_DEF_P/VIEW_DEF");
+
+ g_assert_true (res);
+
+ res = gda_server_provider_perform_operation (fixture->provider,
+ fixture->cnc,
+ op,
+ NULL);
+
+ g_assert_true (res);
+ /* END CREATE_VIEEW OPERATION */
+
+ g_clear_object (&op);
+
+ /* START DROP_VIEW OPERATION */
+ op = gda_server_provider_create_operation (fixture->provider,
+ fixture->cnc,
+ GDA_SERVER_OPERATION_DROP_VIEW,
+ NULL,
+ NULL);
+
+ g_assert_nonnull (op);
+
+ res = gda_server_operation_set_value_at (op,
+ "MyView",
+ NULL,
+ "/VIEW_DESC_P/VIEW_NAME");
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "TRUE",
+ NULL,
+ "/VIEW_DESC_P/VIEW_IFNOTEXISTS");
+
+ g_assert_true (res);
+
+ res = gda_server_provider_perform_operation (fixture->provider,
+ fixture->cnc,
+ op,
+ NULL);
+
+ g_assert_true (res);
+ /* END DROP VIEW OPERATION */
+
+ g_clear_object (&op);
+
+ /* START CREATE_INDEX OPERATION */
+ op = gda_server_provider_create_operation (fixture->provider,
+ fixture->cnc,
+ GDA_SERVER_OPERATION_CREATE_INDEX,
+ NULL,
+ NULL);
+
+ g_assert_nonnull (op);
+
+ res = gda_server_operation_set_value_at (op,
+ "UNIQUE",
+ NULL,
+ "/INDEX_DEF_P/INDEX_TYPE");
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "MyIndex",
+ NULL,
+ "/INDEX_DEF_P/INDEX_NAME");
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "NewEmployee",
+ NULL,
+ "/INDEX_DEF_P/INDEX_ON_TABLE");
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "TRUE",
+ NULL,
+ "/INDEX_DEF_P/INDEX_IFNOTEXISTS");
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "name",
+ NULL,
+ "/INDEX_FIELDS_S/%d/INDEX_FIELD",
+ 0);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "BINARY",
+ NULL,
+ "/INDEX_FIELD_S/%d/INDEX_COLLATE",
+ 0);
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "ASC",
+ NULL,
+ "/INDEX_FIELD_S/%d/INDEX_SORT_ORDER",
+ 0);
+
+ g_assert_true (res);
+
+ res = gda_server_provider_perform_operation (fixture->provider, fixture->cnc, op, NULL);
+
+ g_assert_true (res);
+ /* END CREATE_INDEX OPERATION */
+ g_clear_object (&op);
+
+ /* START DROP_INDEX OPERATION */
+ op = gda_server_provider_create_operation (fixture->provider,
+ fixture->cnc,
+ GDA_SERVER_OPERATION_DROP_INDEX,
+ NULL,
+ NULL);
+
+ g_assert_nonnull (op);
+
+ res = gda_server_operation_set_value_at (op,
+ "MyIndex",
+ NULL,
+ "/INDEX_DESC_P/INDEX_NAME");
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "TRUE",
+ NULL,
+ "/INDEX_DESC_P/INDEX_IFEXISTS");
+
+ g_assert_true (res);
+
+ res = gda_server_provider_perform_operation (fixture->provider,
+ fixture->cnc,
+ op,
+ NULL);
+
+ g_assert_true (res);
+ /* END DROP_INDEX OPERATION */
+
+ g_clear_object (&op);
+
+ /* START DROP_TABLE OPERATION */
+ op = gda_server_provider_create_operation (fixture->provider,
+ fixture->cnc,
+ GDA_SERVER_OPERATION_DROP_TABLE,
+ NULL,
+ NULL);
+
+ g_assert_nonnull (op);
+
+ res = gda_server_operation_set_value_at (op,
+ "NewEmployee",
+ NULL,
+ "/TABLE_DESC_P/TABLE_NAME");
+
+ g_assert_true (res);
+
+ res = gda_server_operation_set_value_at (op,
+ "TRUE",
+ NULL,
+ "/TABLE_DESC_P/TABLE_IFEXISTS");
+
+ g_assert_true (res);
+
+ res = gda_server_provider_perform_operation (fixture->provider,
+ fixture->cnc,
+ op,
+ NULL);
+
+ g_assert_true (res);
+ /* END DROP_TABLE OPERATION */
+
+ g_object_unref (op);
+}
+
+static void
+test_server_operation_operations_db (TestObjectFixture *fixture,
+ G_GNUC_UNUSED gconstpointer user_data)
+{
+
+/* Define table Project */
+ GdaDbTable *tproject = gda_db_table_new ();
+ gda_db_base_set_name (GDA_DB_BASE (tproject), "Project");
+ gda_db_table_set_is_temp (tproject, FALSE);
+
+ /* Defining column id */
+ GdaDbColumn *pid = gda_db_column_new ();
+ gda_db_column_set_name (pid, "id");
+ gda_db_column_set_type (pid, G_TYPE_INT);
+ gda_db_column_set_nnul (pid, TRUE);
+ gda_db_column_set_autoinc (pid, TRUE);
+ gda_db_column_set_unique (pid, TRUE);
+ gda_db_column_set_pkey (pid, TRUE);
+
+ gda_db_table_append_column (tproject, pid);
+
+ g_object_unref (pid);
+
+ /* Defining column name */
+ GdaDbColumn *pname = gda_db_column_new ();
+ gda_db_column_set_name (pname, "name");
+ gda_db_column_set_type (pname, G_TYPE_STRING);
+ gda_db_column_set_size (pname, 50);
+ gda_db_column_set_nnul (pname, TRUE);
+ gda_db_column_set_autoinc (pname, FALSE);
+ gda_db_column_set_unique (pname, TRUE);
+ gda_db_column_set_pkey (pname, FALSE);
+ gda_db_column_set_default (pname, "Default_name");
+
+ gda_db_table_append_column (tproject, pname);
+
+ g_object_unref (pname);
+
+/* Create table */
+ gboolean res = gda_db_table_create (tproject, fixture->cnc, TRUE, NULL);
+
+ g_assert_true (res);
+
+/* Define table Employee */
+ GdaDbTable *temployee = gda_db_table_new ();
+ gda_db_base_set_name (GDA_DB_BASE (temployee), "Employee");
+ gda_db_table_set_is_temp (temployee, FALSE);
+
+ /* Defining column id */
+ GdaDbColumn *eid = gda_db_column_new ();
+ gda_db_column_set_name (eid, "id");
+ gda_db_column_set_type (eid, G_TYPE_INT);
+ gda_db_column_set_nnul (eid, TRUE);
+ gda_db_column_set_autoinc (eid, TRUE);
+ gda_db_column_set_unique (eid, TRUE);
+ gda_db_column_set_pkey (eid, TRUE);
+
+ gda_db_table_append_column (temployee, eid);
+
+ g_object_unref (eid); /* We will reuse this object */
+
+ GdaDbColumn *ename = gda_db_column_new ();
+ gda_db_column_set_name (ename, "name");
+ gda_db_column_set_type (ename, G_TYPE_STRING);
+ gda_db_column_set_size (ename, 50);
+ gda_db_column_set_nnul (ename, TRUE);
+ gda_db_column_set_autoinc (ename, FALSE);
+ gda_db_column_set_unique (ename, TRUE);
+ gda_db_column_set_pkey (ename, FALSE);
+ gda_db_column_set_default (ename, "Default_name");
+
+ gda_db_table_append_column (temployee, ename);
+
+ g_object_unref (ename); /* We will reuse this object */
+
+ GdaDbColumn *project_id = gda_db_column_new();
+ gda_db_column_set_name (project_id, "project_id");
+ gda_db_column_set_type (project_id, G_TYPE_INT);
+ gda_db_column_set_nnul (project_id, TRUE);
+ gda_db_column_set_autoinc (project_id, FALSE);
+ gda_db_column_set_unique (project_id, FALSE);
+ gda_db_column_set_pkey (project_id, FALSE);
+
+ gda_db_table_append_column (temployee, project_id);
+
+ g_object_unref (project_id);
+
+/* Creating Foreign key */
+ GdaDbFkey *fkey = gda_db_fkey_new ();
+ gda_db_fkey_set_ref_table (fkey, "Project");
+ gda_db_fkey_set_ondelete (fkey, GDA_DB_FKEY_RESTRICT);
+ gda_db_fkey_set_onupdate (fkey, GDA_DB_FKEY_RESTRICT);
+ gda_db_fkey_set_field (fkey, "project_id", "id");
+
+ gda_db_table_append_fkey (temployee, fkey);
+
+ g_object_unref (fkey);
+
+ res = gda_db_table_create (temployee, fixture->cnc, TRUE, NULL);
+
+ g_assert_true (res);
+
+ /* Start of ADD_COLUMN operation */
+ GdaDbColumn *cost = gda_db_column_new ();
+ gda_db_column_set_name (cost, "cost");
+ gda_db_column_set_type (cost, G_TYPE_FLOAT);
+ gda_db_column_set_size (cost, 5);
+ gda_db_column_set_scale (cost, 2);
+ gda_db_column_set_nnul (cost, FALSE);
+
+ res = gda_db_table_add_column (tproject, cost, fixture->cnc, NULL);
+
+ g_assert_true (res);
+
+ g_object_unref (cost);
+ g_object_unref (tproject);
+
+/* RENAME_TABLE operation */
+ GdaDbTable *new_table = gda_db_table_new ();
+ gda_db_base_set_name (GDA_DB_BASE (new_table), "NewEmployee");
+
+ res = gda_db_table_rename (temployee, new_table, fixture->cnc, NULL);
+
+ g_assert_true (res);
+
+ GdaDbView *myview = gda_db_view_new ();
+ gda_db_base_set_name (GDA_DB_BASE (myview), "MyView");
+ gda_db_view_set_istemp (myview, FALSE);
+ gda_db_view_set_defstring (myview, "SELECT name, project_id FROM NewEmployee");
+
+ res = gda_db_view_create (myview, fixture->cnc, TRUE, NULL);
+
+ /* DROP_VIEW operation. We will reuse the view */
+ res = gda_db_view_drop (myview, fixture->cnc, TRUE, GDA_DB_VIEW_RESTRICT, NULL);
+
+ g_assert_true (res);
+
+ GdaDbIndex *index = gda_db_index_new ();
+
+ gda_db_index_set_unique (index, TRUE);
+ gda_db_base_set_name (GDA_DB_BASE (index), "MyIndex"); // GdaDBIndex is derived from GdaDbBase
+
+ GdaDbIndexField *field = gda_db_index_field_new ();
+
+ GdaDbColumn *fcol = gda_db_column_new ();
+
+ gda_db_column_set_name (fcol, "name");
+
+ gda_db_index_field_set_column (field, fcol);
+ gda_db_index_field_set_collate (field, GDA_DB_INDEX_COLLATE_BINARY);
+ gda_db_index_field_set_sort_order (field, GDA_DB_INDEX_SORT_ORDER_ASC);
+
+ gda_db_index_append_field (index, field);
+ g_object_unref (fcol);
+ g_object_unref (field);
+
+ res = gda_db_table_add_index (new_table, index, fixture->cnc, TRUE, NULL);
+
+ g_assert_true (res);
+
+ res = gda_db_index_drop (index, fixture->cnc, TRUE, NULL);
+
+ g_assert_true (res);
+
+ res = gda_db_table_drop (new_table, fixture->cnc, TRUE, NULL);
+
+ g_assert_true (res);
+}
+
+gint
+main(gint argc, gchar *argv[])
+{
+ setlocale (LC_ALL,"");
+
+ g_test_init (&argc,&argv,NULL);
+
+ g_test_add ("/test-server-operation-sqlite/old-so-module",
+ TestObjectFixture,
+ NULL,
+ test_server_operation_start,
+ test_server_operation_operations,
+ test_server_operation_finish);
+
+ g_test_add ("/test-server-operation-sqlite/gda-db-module",
+ TestObjectFixture,
+ NULL,
+ test_server_operation_start,
+ test_server_operation_operations_db,
+ test_server_operation_finish);
+
+ return g_test_run();
+}
+
[
Date Prev][
Date Next] [
Thread Prev][
Thread Next]
[
Thread Index]
[
Date Index]
[
Author Index]
