Changeset 4428 for trunk/psLib/src/db

Timestamp:

Jun 29, 2005, 9:40:23 AM (21 years ago)

Author:

evanalst

Message:

Update function psDBDeleteRows to include limit of maximum rows to delete.

File:

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

trunk/psLib/src/db/psDB.c

@@ -12 +12 @@
  *  @author Joshua Hoblitt
  *
- *  @version $Revision: 1.35 $ $Name: not supported by cvs2svn $
- *  @date $Date: 2005-06-25 02:44:14 $
+ *  @version $Revision: 1.36 $ $Name: not supported by cvs2svn $
+ *  @date $Date: 2005-06-29 19:40:23 $
  *
  *  Copyright 2005 Joshua Hoblitt, University of Hawaii
@@ -52 +52 @@
 static char    *psDBGenerateInsertRowSQL(const char *tableName, const psMetadata *row);
 static char    *psDBGenerateUpdateRowSQL(const char *tableName, const psMetadata *where, const psMetadata *values);
-static char    *psDBGenerateDeleteRowSQL(const char *tableName, const psMetadata *where);
+static char    *psDBGenerateDeleteRowSQL(const char *tableName, const psMetadata *where, unsigned long long limit);
 static char    *psDBGenerateWhereSQL(const psMetadata *where);
 static char    *psDBGenerateSetSQL(const psMetadata *set
@@ -778 +778 @@
 }
 
-psS64 psDBDeleteRows(psDB *dbh, const char *tableName, const psMetadata *where)
+psS64 psDBDeleteRows(psDB *dbh, const char *tableName, const psMetadata *where, unsigned long long limit)
 {
     char            *query;
@@ -790 +790 @@
 
     // Create SQL statement string
-    query = psDBGenerateDeleteRowSQL(tableName, where);
+    query = psDBGenerateDeleteRowSQL(tableName, where,limit);
     if (!query) {
         psError(PS_ERR_UNEXPECTED_NULL, false, "Query generation failed.");
@@ -1130 +1130 @@
 }
 
-static char *psDBGenerateDeleteRowSQL(const char *tableName, const psMetadata *where)
+static char *psDBGenerateDeleteRowSQL(const char *tableName, const psMetadata *where, unsigned long long limit)
 {
     char            *query = NULL;
     char            *whereSQL;
+    char            *limitString;
 
     // delete all rows if where is NULL
@@ -1148 +1149 @@
     }
 
+    psStringAppend(&query, "DELETE FROM %s %s", tableName, whereSQL);
+
     // Complete delete SQL command string
-    psStringAppend(&query, "DELETE FROM %s %s", tableName, whereSQL);
+    // treat limit == 0 as "no limit"
+    if (limit) {
+        limitString = psDBIntToString(limit);
+        psStringAppend(&query, " LIMIT %s", limitString);
+        psFree(limitString);
+    }
     psFree(whereSQL);