Changeset 3202

Timestamp:

Feb 11, 2005, 4:40:21 PM (21 years ago)

Author:

jhoblitt

Message:

fix dereference error in psDBSelectRows()
add psDBDumpCols()
add psDBMySQLToPType()

Location:

trunk/archive/psdb

Files:

• psDB.c (modified) (5 diffs)
• psDB.h (modified) (2 diffs)
• test.c (modified) (4 diffs)

trunk/archive/psdb/psDB.c

@@ -8 +8 @@
  *  @author Joshua Hoblitt
  *
- *  @version $Revision: 1.16 $ $Name: not supported by cvs2svn $
- *  @date $Date: 2005-02-11 23:46:57 $
+ *  @version $Revision: 1.17 $ $Name: not supported by cvs2svn $
+ *  @date $Date: 2005-02-12 02:40:21 $
  *
  *  Copyright 2005 Joshua Hoblitt, University of Hawaii
@@ -41 +41 @@
 static void     psDBPSToMySQLTableCleanup(void);
 static psPtr    psDBMySQLTypeAlloc(enum enum_field_types type, bool isUnsigned);
+static psU32 psDBMySQLToPType(psU32 type, psU32 flags);
 
 // pType utility functions
@@ -421 +422 @@
             // signed or unsigned.  The result is this ugly conversion from
             // mysql -> ascii -> ptype
-            if (field->flags & UNSIGNED_FLAG) {
+            if (field[i].flags & UNSIGNED_FLAG) {
                 psStringPrepend(&sqlType, "UNSIGNED ");
             }
@@ -582 +583 @@
 {
     return psDBSelectRows(dbh, tableName, NULL);
+}
+
+psMetadata *psDBDumpCols(psDB *dbh, const char *tableName)
+{
+    MYSQL_RES       *result;
+    MYSQL_FIELD     *field;
+    psU32           fieldCount;
+    psMetadata      *table;
+    psMetadataItem  *item;
+    psU32           pType;
+    psU32           i;
+    psPtr           column;
+
+    // find column types
+    result = mysql_list_fields(dbh->mysql, tableName, NULL);
+    field = mysql_fetch_fields(result);
+    fieldCount = mysql_num_fields(result);
+
+    table = psMetadataAlloc();
+
+    // fetch each column and load into psMetadata
+    for (i =0; i < fieldCount; i++) {
+        // find ptype of column
+        pType = psDBMySQLToPType(field[i].type, field[i].flags);
+        
+        // if the ptype is PS_TYPE_PTR assume that it's a string and fetch the
+        // column as an psArray of strings; otherwise fetch the column as a
+        // psVector.  
+        if (pType == PS_TYPE_PTR) {
+            // PS_META_UNKNOWN -> PS_META_ARRAY ?
+            column = psDBSelectColumn(dbh, tableName, field[i].name, 0);
+            item = psMetadataItemAlloc(field[i].name, PS_TYPE_PTR, PS_META_UNKNOWN, "psArray", column);
+            psMetadataAddItem(table, item, 0);
+            psFree(column);
+            psFree(item);
+        } else {
+            column = psDBSelectColumnNum(dbh, tableName, field[i].name, pType, 0);
+            item = psMetadataItemAlloc(field[i].name, PS_TYPE_PTR, PS_META_VEC, "psVector", column);
+            psMetadataAddItem(table, item, 0);
+            //psFree(column);
+            psFree(item);
+        }
+    }
+    
+    return table;
 }
 
@@ -1225 +1271 @@
 
     return newSize;
+}
+
+static psU32 psDBMySQLToPType(psU32 type, psU32 flags)
+{
+    psHash          *mysqlToSQLTable;   // type lookup table
+    psHash          *sqlToPSTable;      // type lookup table
+    char            *key;               // hash tmp value
+    char            *value;             // hash tmp value
+    char            *sqlType;           // copy of lookup table result
+    psU32           pType;              // psElemType of a field
+
+    mysqlToSQLTable = psDBGetMySQLToSQLTable();
+    sqlToPSTable    = psDBGetSQLToPSTable();
+
+    // lookup MySQL column type
+    key     = psDBIntToString((psU64)type); 
+    value   = psHashLookup(mysqlToSQLTable, key);
+    sqlType = psStringCopy(value);
+    psFree(key);
+
+    // MySQL column types can not be directly translated to PS
+    // types as the the mysql types do not tell you if the value is
+    // signed or unsigned.  The result is this ugly conversion from
+    // mysql -> ascii -> ptype
+    if (flags & UNSIGNED_FLAG) {
+        psStringPrepend(&sqlType, "UNSIGNED ");
+    }
+
+    // convert MySQL type to PS type
+    value = psHashLookup(sqlToPSTable, sqlType);
+    pType = (psU32)atol(value);
+    psFree(sqlType);
+
+    return pType;
 }
 

trunk/archive/psdb/psDB.h

@@ -10 +10 @@
  *  @author Joshua Hoblitt
  *
- *  @version $Revision: 1.5 $ $Name: not supported by cvs2svn $
- *  @date $Date: 2005-02-10 20:56:41 $
+ *  @version $Revision: 1.6 $ $Name: not supported by cvs2svn $
+ *  @date $Date: 2005-02-12 02:40:21 $
  *
  *  Copyright 2005 Joshua Hoblitt, University of Hawaii
@@ -55 +55 @@
 psArray *psDBDumpRows(psDB *dbh, const char *tableName);
 
+psMetadata *psDBDumpCols(psDB *dbh, const char *tableName);
+
 psS64 psDBUpdateRows(psDB *dbh, const char *tableName, psMetadata *where, psMetadata *values);
 

trunk/archive/psdb/test.c

@@ -147 +147 @@
     }
 
-    // psDBInsertOneRow();
+    // psDBInsertOneRow()
     {
         psMetadata      *md;
@@ -162 +162 @@
     }
 
-    // psDBInsertRows();
+    // psDBInsertRows()
     {
         psArray         *rowSet;
@@ -197 +197 @@
     }
 
-    // psDBDumpRows();
+    // psDBDumpRows()
     {
         psArray         *resultSet;
@@ -206 +206 @@
     }
 
-    // psDBUpdateRows();
+    // psDBDumpCols()
+    {
+        psMetadata      *columns;
+        psMetadataItem  *item;
+        psListIterator  *cursor;
+
+        columns = psDBDumpCols(dbh, "horse");
+        OK(columns, "psDBDumpCols()");
+
+        cursor = psListIteratorAlloc(columns->list, 0);
+
+        while ((item = psListGetNext(cursor))) {
+            printf("column name is: %s\n", item->name);
+        }
+
+        psFree(cursor);
+        psFree(columns);
+    }
+
+    // psDBUpdateRows()
     {
         psMetadata      *where;