From d488da00476f154b160e2f9548d031b636878b2e Mon Sep 17 00:00:00 2001 From: Andrea Zagli Date: Fri, 2 Jul 2010 17:41:00 +0200 Subject: [PATCH] Implemented Dbt::parse_gda_op. --- .gitignore | 1 + src/dbtransformer.c | 123 +++++++++++++++++++++++++++++++++++++++++++- tests/test.db | Bin 5120 -> 7168 bytes tests/test.xml | 28 ++++++++++ 4 files changed, 150 insertions(+), 2 deletions(-) diff --git a/.gitignore b/.gitignore index bb9762b..d4cf8a5 100644 --- a/.gitignore +++ b/.gitignore @@ -49,3 +49,4 @@ Rules-quot *.exe .cproject .project +.settings diff --git a/src/dbtransformer.c b/src/dbtransformer.c index afe2c94..94f758c 100644 --- a/src/dbtransformer.c +++ b/src/dbtransformer.c @@ -304,6 +304,13 @@ dbt_check_db (Dbt *dbt) gda_server_operation_set_value_at (op, "operation", &error, "/FIELDS_A/@COLUMN_NAME/%d", i); gda_server_operation_set_value_at (op, "text", &error, "/FIELDS_A/@COLUMN_TYPE/%d", i); + /* + xmlNodePtr xnode2 = gda_server_operation_save_data_to_xml (op, &error); + xmlDocPtr xdoc2 = xmlNewDoc ("1.0"); + xmlDocSetRootElement (xdoc2, xnode2); + xmlSaveFormatFile("-",xdoc2,2); + */ + /* execute the operation */ if (!gda_server_provider_perform_operation (provider, priv->gda_conn, op, &error)) { @@ -467,6 +474,118 @@ dbt_parse_sql (Dbt *dbt, xmlNodePtr xnode) return ret; } +static gboolean +dbt_parse_gda_op (Dbt *dbt, xmlNodePtr xnode) +{ + DbtPrivate *priv; + + gboolean ret; + + xmlNodePtr cur; + + gchar *str_operation_type; + GdaServerOperationType operation_type; + GdaServerProvider *provider; + GError *error; + GdaServerOperation *op; + + ret = TRUE; + + priv = DBT_GET_PRIVATE (dbt); + + cur = xnode->children; + while (cur != NULL && ret) + { + if (xmlNodeIsText (cur)) + { + cur = cur->next; + continue; + } + + if (xmlStrcmp (cur->name, (const xmlChar *)"serv_op_data") != 0) + { + g_warning ("Invalid tag \"%s\".\n", cur->name); + ret = FALSE; + cur = cur->next; + continue; + } + + str_operation_type = (gchar *)xmlGetProp(cur, (const xmlChar *)"type"); + + /* TODO + * must find the GdaServerOperationType of the string + * i asked on gda mailing list + * for now i implement it + */ + operation_type = GDA_SERVER_OPERATION_LAST; + if (g_strcmp0 (str_operation_type, "CREATE_DB") == 0) operation_type = GDA_SERVER_OPERATION_CREATE_DB; + if (g_strcmp0 (str_operation_type, "DROP_DB") == 0) operation_type = GDA_SERVER_OPERATION_DROP_DB; + if (g_strcmp0 (str_operation_type, "CREATE_TABLE") == 0) operation_type = GDA_SERVER_OPERATION_CREATE_TABLE; + if (g_strcmp0 (str_operation_type, "DROP_TABLE") == 0) operation_type = GDA_SERVER_OPERATION_DROP_TABLE; + if (g_strcmp0 (str_operation_type, "CREATE_INDEX") == 0) operation_type = GDA_SERVER_OPERATION_CREATE_INDEX; + if (g_strcmp0 (str_operation_type, "DROP_INDEX") == 0) operation_type = GDA_SERVER_OPERATION_DROP_INDEX; + if (g_strcmp0 (str_operation_type, "RENAME_TABLE") == 0) operation_type = GDA_SERVER_OPERATION_RENAME_TABLE; + if (g_strcmp0 (str_operation_type, "COMMENT_TABLE") == 0) operation_type = GDA_SERVER_OPERATION_COMMENT_TABLE; + if (g_strcmp0 (str_operation_type, "ADD_COLUMN") == 0) operation_type = GDA_SERVER_OPERATION_ADD_COLUMN; + if (g_strcmp0 (str_operation_type, "DROP_COLUMN") == 0) operation_type = GDA_SERVER_OPERATION_DROP_COLUMN; + if (g_strcmp0 (str_operation_type, "COMMENT_COLUMN") == 0) operation_type = GDA_SERVER_OPERATION_COMMENT_COLUMN; + if (g_strcmp0 (str_operation_type, "CREATE_VIEW") == 0) operation_type = GDA_SERVER_OPERATION_CREATE_VIEW; + if (g_strcmp0 (str_operation_type, "DROP_VIEW") == 0) operation_type = GDA_SERVER_OPERATION_DROP_VIEW; + if (g_strcmp0 (str_operation_type, "CREATE_USER") == 0) operation_type = GDA_SERVER_OPERATION_CREATE_USER; + if (g_strcmp0 (str_operation_type, "DROP_USER") == 0) operation_type = GDA_SERVER_OPERATION_DROP_USER; + if (g_strcmp0 (str_operation_type, "ALTER_USER") == 0) operation_type = GDA_SERVER_OPERATION_ALTER_USER; + + if (operation_type == GDA_SERVER_OPERATION_LAST) + { + g_warning ("Operation type \"%s\" not supported.\n%s\n", str_operation_type, + error && error->message ? error->message : "No detail"); + return FALSE; + } + + provider = gda_connection_get_provider (priv->gda_conn); + if (gda_server_provider_supports_operation (provider, priv->gda_conn, operation_type, NULL)) + { + error = NULL; + op = gda_server_provider_create_operation (provider, priv->gda_conn, operation_type, NULL, &error); + if (!op) + { + g_warning ("Unable to create operation type \"%s\".\n%s\n", str_operation_type, + error && error->message ? error->message : "No detail"); + ret = FALSE; + } + else + { + error = NULL; + if (!gda_server_operation_load_data_from_xml (op, cur, &error)) + { + g_warning ("Unable to load GdaServerOperation from the file.\n%s\n", + error && error->message ? error->message : "No detail"); + ret = FALSE; + } + else + { + if (!gda_server_provider_perform_operation (provider, priv->gda_conn, op, &error)) + { + g_warning ("Error on executing GdaServerOperation from the file.\n%s\n", + error && error->message ? error->message : "No detail"); + ret = FALSE; + } + } + g_object_unref (op); + } + } + else + { + g_warning ("Operation type \"%s\" not supported by the provider.\n", str_operation_type); + ret = FALSE; + } + + cur = cur->next; + } + + return ret; +} + void dbt_transform (Dbt *dbt) { @@ -532,10 +651,10 @@ dbt_transform (Dbt *dbt) { tosave = dbt_parse_sql (dbt, xnode); } - /*else if (xmlStrcmp (xnode->name, (const xmlChar *)"gda_op") == 0) + else if (xmlStrcmp (xnode->name, (const xmlChar *)"gda_op") == 0) { tosave = dbt_parse_gda_op (dbt, xnode); - }*/ + } else { g_warning ("Invalid tag: %s", xnode->name); diff --git a/tests/test.db b/tests/test.db index a8d2e0623528daa422ee491817b71f1c9d38584b..a9fddd1624212b486cf7307dff87f6dfbdd69a05 100644 GIT binary patch literal 7168 zcmeHMPmhy86bIUFvnD3qnvK~wAs)6#ld8?$+D4XA#ig`cAaT8r*=2T1WT6YQ|Du-~ zFJApN-aPsp`~-dr2L|F`x~3tkNh6cM43Bw#_|3e$_XguYb1?!ZL3jo+=x|kz=eg$q za2!`77uz<-gTN4YX8gzDee$-(|KKWLD|^B>VV4Zc_OB6mRoiH6Z}TpOM;`LgRj%KV zr;21Mz?Akh1!Ql*j_Ux|$LJJ=U@}!l()1AQD~HX+gKE98wZ$*qB~pUWL19GiwVWhM zW977f>)6Mhi+r4kZUNDO7>OXhw*U?>^nepw5Ib8y9_xlVl~mmXRG2+~i*8tJV(HE1 zb*0{T_>f<`NGzfXqO_~#Y)XlFqkMRVz$FZiXE5B^ebUS+PC0JT{9dRxIvsxTDADX3 zVH=0gkElnvfgdd)RdN&ykpyUq|8Gs!xnUzyWbBu`p3Gh(za0jZ4t>*DaGoh1Ty zk3i}FcaLc)u|!~95GehBT~?~Jvqa$UAi$P)rZSp{{h_28%1X5z%c~Ccv8lXP4bxan z#86eVfniH&@kt9-7>4jBDN|`pnbxtC90pezm7RSFy$b}611~OqX`yJ-Le+J;?YIo4 z?8&@U1(=5uQt77W--V?Z>KjD_ZscEhUQfhgdsX#@ENR6!b=}emsgx{ptm<+hUQ1UG ztYY>~$Ug4f-dG(>D%F9h=arm|6S!#TY YLw8c%P04u(bI=pdpj^o@(31N9CkmRJTmS$7 delta 131 zcmZp$XwaA-E$G643M?k-*zmA0nKCdRV0L0U!DPBwkmVqwOrrn`ySStzV`FtmVp2|O zeo;zlQ89#MnH + + + + newtable + FALSE + FALSE + + + + id + integer + + + + + + TRUE + + + + + + + + + + + -- 2.49.0