Changeset 7070 for trunk/psLib/src/db/psDB.c

Timestamp:

May 4, 2006, 4:42:01 PM (20 years ago)

Author:

Paul Price

Message:

Applying patch from Josh Hoblitt: Patch to add transaction control to psdb

File:

• trunk/psLib/src/db/psDB.c (modified) (6 diffs)

trunk/psLib/src/db/psDB.c

@@ -12 +12 @@
  *  @author Joshua Hoblitt
  *
- *  @version $Revision: 1.49 $ $Name: not supported by cvs2svn $
- *  @date $Date: 2006-05-03 02:35:37 $
+ *  @version $Revision: 1.50 $ $Name: not supported by cvs2svn $
+ *  @date $Date: 2006-05-05 02:42:01 $
  *
  *  Copyright 2005 Joshua Hoblitt, University of Hawaii
@@ -123 +123 @@
     dbh->mysql = mysql;
 
+    // explicit transactions default to false
+    if (!psDBExplicitTrans(dbh, false)) {
+        psError(PS_ERR_UNKNOWN, true,
+                "failed to set transaction type", mysql_error(mysql));
+
+        mysql_close(mysql);
+        psFree(dbh);
+
+        return NULL;
+    }
+
     return dbh;
 }
@@ -688 +699 @@
     } // end loop over rows
 
-    // point of no return
-    mysql_commit(dbh->mysql);
-
     psFree(bind);
     mysql_stmt_close(stmt);
@@ -838 +846 @@
     rowsAffected = mysql_stmt_affected_rows(stmt);
 
-    // point of no return
-    mysql_commit(dbh->mysql);
-
     mysql_stmt_close(stmt);
 
@@ -879 +884 @@
     rows = (psS64)mysql_affected_rows(dbh->mysql);
 
-    // point of no return
-    mysql_commit(dbh->mysql);
-
     return rows;
 }
@@ -890 +892 @@
     return (long)mysql_insert_id(dbh->mysql);
 }
+
+bool psDBExplicitTrans(psDB *dbh, bool mode)
+{
+    // Verify database is not NULL
+    if(dbh == NULL) {
+        psError(PS_ERR_UNEXPECTED_NULL, true, PS_ERRORTEXT_psDB_INVALID_PSDB);
+        return false;
+    }
+
+    // mode needs to be inverted as autocommits are the opposide of explicit
+    // transactions.
+    // the return value also needs to be inverted for the same reason.
+    // is it safe to assume my_bool always safely casts to bool?
+    return !(bool)mysql_autocommit(dbh->mysql, !mode);
+}
+
+bool psDBTransaction(psDB *dbh)
+{
+    // Verify database is not NULL
+    if(dbh == NULL) {
+        psError(PS_ERR_UNEXPECTED_NULL, true, PS_ERRORTEXT_psDB_INVALID_PSDB);
+        return false;
+    }
+
+    bool status = p_psDBRunQuery(dbh, "START TRANSACTION");
+    if (!status) {
+        psError(PS_ERR_UNKNOWN, false, "Failed to create new database.");
+    }
+
+    return status;
+}
+
+bool psDBCommit(psDB *dbh)
+{
+    // Verify database is not NULL
+    if(dbh == NULL) {
+        psError(PS_ERR_UNEXPECTED_NULL, true, PS_ERRORTEXT_psDB_INVALID_PSDB);
+        return false;
+    }
+
+    // is it safe to assume my_bool always safely casts to bool?
+    return (bool)mysql_commit(dbh->mysql);
+}
+
+bool psDBRollback(psDB *dbh)
+{
+    // Verify database is not NULL
+    if(dbh == NULL) {
+        psError(PS_ERR_UNEXPECTED_NULL, true, PS_ERRORTEXT_psDB_INVALID_PSDB);
+        return false;
+    }
+
+    // is it safe to assume my_bool always safely casts to bool?
+    return (bool)mysql_rollback(dbh->mysql);
+}
+
 
 // database utility functions