You are viewing a plain text version of this content. The canonical link for it is here.
Posted to sandesha-dev@ws.apache.org by da...@apache.org on 2007/04/26 06:34:15 UTC

svn commit: r532604 - in /webservices/sandesha/trunk/c/src/storage/mysql: permanent_bean_mgr.c permanent_seq_property_mgr.c permanent_transaction.c

Author: damitha
Date: Wed Apr 25 21:34:12 2007
New Revision: 532604

URL: http://svn.apache.org/viewvc?view=rev&rev=532604
Log:
use mysql_commmit and mysql_rollback instead of mysql_query(&connection, "commit") etc

Modified:
    webservices/sandesha/trunk/c/src/storage/mysql/permanent_bean_mgr.c
    webservices/sandesha/trunk/c/src/storage/mysql/permanent_seq_property_mgr.c
    webservices/sandesha/trunk/c/src/storage/mysql/permanent_transaction.c

Modified: webservices/sandesha/trunk/c/src/storage/mysql/permanent_bean_mgr.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/storage/mysql/permanent_bean_mgr.c?view=diff&rev=532604&r1=532603&r2=532604
==============================================================================
--- webservices/sandesha/trunk/c/src/storage/mysql/permanent_bean_mgr.c (original)
+++ webservices/sandesha/trunk/c/src/storage/mysql/permanent_bean_mgr.c Wed Apr 25 21:34:12 2007
@@ -103,25 +103,6 @@
             bean = sandesha2_msg_store_bean_create(env);
             args->data = bean;
         }
-        /*printf("row0:%s\n", row[0]);
-        printf("row1:%s\n", row[1]);
-        printf("row2:%s\n", row[2]);
-        printf("row3:%s\n", row[3]);
-        printf("row4:%s\n", row[4]);
-        printf("row5:%s\n", row[5]);
-        printf("row6:%s\n", row[6]);
-        printf("row7:%s\n", row[7]);
-        printf("row8:%s\n", row[8]);
-        printf("row9:%s\n", row[9]);
-        printf("row10:%s\n", row[10]);
-        printf("row11:%s\n", row[11]);
-        printf("row12:%s\n", row[12]);
-        printf("row13:%s\n", row[13]);
-        printf("row14:%s\n", row[14]);
-        printf("row15:%s\n", row[15]);
-        printf("row16:%s\n", row[16]);
-        printf("row17:%s\n", row[17]);
-        printf("row18:%s\n", row[18]);*/
         sandesha2_msg_store_bean_set_stored_key(bean, env, row[0]);
         sandesha2_msg_store_bean_set_msg_id(bean, env, row[1]);
         sandesha2_msg_store_bean_set_soap_envelope_str(bean, env, row[2]);

Modified: webservices/sandesha/trunk/c/src/storage/mysql/permanent_seq_property_mgr.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/storage/mysql/permanent_seq_property_mgr.c?view=diff&rev=532604&r1=532603&r2=532604
==============================================================================
--- webservices/sandesha/trunk/c/src/storage/mysql/permanent_seq_property_mgr.c (original)
+++ webservices/sandesha/trunk/c/src/storage/mysql/permanent_seq_property_mgr.c Wed Apr 25 21:34:12 2007
@@ -326,7 +326,6 @@
         seq_id, name);
     sprintf(sql_retrieve, "select seq_id, name, value from seq_property "\
         "where id='%s'", key);
-    printf("sql_retrieve:%s\n", sql_retrieve);
     ret = (sandesha2_seq_property_bean_t *) sandesha2_permanent_bean_mgr_retrieve(
         seq_prop_mgr_impl->bean_mgr, env, sandesha2_seq_property_retrieve_callback, 
         sql_retrieve);

Modified: webservices/sandesha/trunk/c/src/storage/mysql/permanent_transaction.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/storage/mysql/permanent_transaction.c?view=diff&rev=532604&r1=532603&r2=532604
==============================================================================
--- webservices/sandesha/trunk/c/src/storage/mysql/permanent_transaction.c (original)
+++ webservices/sandesha/trunk/c/src/storage/mysql/permanent_transaction.c Wed Apr 25 21:34:12 2007
@@ -249,7 +249,7 @@
     trans_impl = SANDESHA2_INTF_TO_IMPL(trans);
    
     axutil_thread_mutex_lock(trans_impl->mutex);
-    rc = mysql_query(trans_impl->dbconn, "commit;");
+    rc = mysql_commit(trans_impl->dbconn);
     if(rc )
     {
         mysql_close(trans_impl->dbconn);
@@ -274,7 +274,7 @@
     sandesha2_permanent_transaction_impl_t *trans_impl = NULL;
     trans_impl = SANDESHA2_INTF_TO_IMPL(trans);
     axutil_thread_mutex_lock(trans_impl->mutex);
-    rc = mysql_query(trans_impl->dbconn, "rollback;");
+    rc = mysql_rollback(trans_impl->dbconn);
     if(rc )
     {
         mysql_close(trans_impl->dbconn);



---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org