From d69845b1aaa0d3ea71d5df8174104cc0f144969c Mon Sep 17 00:00:00 2001
From: Marco van Wieringen <mvw@planets.elm.net>
Date: Sat, 20 Feb 2010 16:22:17 +0100
Subject: [PATCH] Added patch from Stefan Reddig -- improved ingres db test

---
 bacula/src/tools/ing_test.c | 73 ++++++++++++++++++++++++++++++++-----
 1 file changed, 64 insertions(+), 9 deletions(-)

diff --git a/bacula/src/tools/ing_test.c b/bacula/src/tools/ing_test.c
index 362018d592..3576087dcf 100644
--- a/bacula/src/tools/ing_test.c
+++ b/bacula/src/tools/ing_test.c
@@ -31,12 +31,11 @@
  *
  *   Stefan Reddig, February 2010
  *
- *   reusing code from 'bvfs_test.c' by
+ *   reusing code by
  *   Eric Bollengier, August 2009
  *
  *
  */
-
 #include "bacula.h"
 #include "cats/cats.h"
 #include "cats/bvfs.h"
@@ -73,6 +72,13 @@ PROG_COPYRIGHT
    exit(1);
 }
 
+/* simple handler for debug output of CRUD example*/
+static int test_handler(void *ctx, int num_fields, char **row)
+{
+   Dmsg2(200, "   Values are %d, %s\n", str_to_int64(row[0]), row[1]);
+   return 0;
+}
+
 
 
 /* number of thread started */
@@ -184,6 +190,11 @@ int main (int argc, char *argv[])
       Pmsg2(000, _("Using Database: %s, User: %s\n"), db_name, db_user);
    }
    
+
+   /* simple CRUD test including create/drop table */
+
+   Pmsg0(0, "\nsimple CRUD test...\n\n");
+
    Dmsg0(200, "DB-Statement: CREATE TABLE t1 ( c1 integer, c2 varchar(29))\n");
    if (!db_sql_query(db, "CREATE TABLE t1 ( c1 integer, c2 varchar(29))", NULL, NULL))
    {
@@ -196,20 +207,64 @@ int main (int argc, char *argv[])
       Emsg0(M_ERROR_TERM, 0, _("INSERT-Stmt went wrong\n"));
    }
 
+   Dmsg0(200, "DB-Statement: SELECT * FROM t1 (should be 1, foo)\n");
+   if (!db_sql_query(db, "SELECT * FROM t1", test_handler, NULL))
+   {
+      Emsg0(M_ERROR_TERM, 0, _("SELECT-Stmt went wrong\n"));
+   }
+
+   Dmsg0(200, "DB-Statement: UPDATE t1 SET c2='bar' WHERE c1=1\n");
+   if (!db_sql_query(db, "UPDATE t1 SET c2='bar' WHERE c1=1", NULL, NULL))
+   {
+      Emsg0(M_ERROR_TERM, 0, _("UPDATE-Stmt went wrong\n"));
+   }
+
+   Dmsg0(200, "DB-Statement: SELECT * FROM t1 (should be 1, bar)\n");
+   if (!db_sql_query(db, "SELECT * FROM t1", test_handler, NULL))
+   {
+      Emsg0(M_ERROR_TERM, 0, _("SELECT-Stmt went wrong\n"));
+   }
+
+   Dmsg0(200, "DB-Statement: DELETE FROM t1 WHERE c2 LIKE '%r'\n");
+   if (!db_sql_query(db, "DELETE FROM t1 WHERE c2 LIKE '%r'", NULL, NULL))
+   {
+      Emsg0(M_ERROR_TERM, 0, _("DELETE-Stmt went wrong\n"));
+   }
+
+   Dmsg0(200, "DB-Statement: SELECT * FROM t1 (should be 0 rows)\n");
+   if (!db_sql_query(db, "SELECT * FROM t1", test_handler, NULL))
+   {
+      Emsg0(M_ERROR_TERM, 0, _("SELECT-Stmt went wrong\n"));
+   }
+
    Dmsg0(200, "DB-Statement: DROP TABLE t1\n");
    if (!db_sql_query(db, "DROP TABLE t1", NULL, NULL))
    {
       Emsg0(M_ERROR_TERM, 0, _("DROP-Stmt went wrong\n"));
    }
 
-/*
-   if (clean) {
-      Pmsg0(0, "Clean old table\n");
-      db_sql_query(db, "DELETE FROM PathHierarchy", NULL, NULL);
-      db_sql_query(db, "UPDATE Job SET HasCache=0", NULL, NULL);
-      db_sql_query(db, "DELETE FROM PathVisibility", NULL, NULL);
+   /* datatypes test */
+   Pmsg0(0, "\ndatatypes test... (TODO)\n\n");
+
+
+   Dmsg0(200, "DB-Statement: CREATE TABLE for datatypes\n");
+   if (!db_sql_query(db, "CREATE TABLE t2 ("
+     "c1	integer,"
+     "c2	varchar(255),"
+     "c3	char(255)"
+     /* some more datatypes... "c4	," */
+     ")" , NULL, NULL))
+   {
+      Emsg0(M_ERROR_TERM, 0, _("CREATE-Stmt went wrong\n"));
    }
-*/
+
+   Dmsg0(200, "DB-Statement: DROP TABLE for datatypes\n");
+   if (!db_sql_query(db, "DROP TABLE t2", NULL, NULL))
+   {
+      Emsg0(M_ERROR_TERM, 0, _("DROP-Stmt went wrong\n"));
+   }
+
+
    db_close_database(NULL, db);
    Dmsg0(200, "Database closed\n");
 
-- 
2.39.5