Changeset 44

Show
Ignore:
Timestamp:
11/10/07 17:45:10 (10 months ago)
Author:
nlawren2
Message:

--

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • vowfsc/db.c

    r43 r44  
    163163        PGresult *res=PQexec(pq_conn,pq_request); 
    164164 
     165        // Check for returned data 
    165166        if( PQresultStatus(res) != PGRES_TUPLES_OK ) return NULL; 
    166167         
    …… 
    177178        file_t *stat=malloc(sizeof(file_t)); 
    178179 
     180        // Make PQ request 
    179181        char pq_request[BUFFER_SIZE]; 
    180182        sprintf(pq_request,"SELECT * " 
    …… 
    184186        PGresult *res=PQexec(pq_conn,pq_request); 
    185187 
     188        // Initialize format 
    186189        if( NUM_FILE_FIELDS ){ 
    187190                NUM_FILE_FIELDS = sizeof(file_format)/4; 
    …… 
    216219        file_t *stat=malloc(sizeof(file_t)); 
    217220 
     221        // Make PQ request 
    218222        char pq_request[BUFFER_SIZE]; 
    219223        sprintf(pq_request,"SELECT * " 
    …… 
    224228        PGresult *res=PQexec(pq_conn,pq_request); 
    225229 
     230        // Initialize format 
    226231        if( NUM_FILE_FIELDS ){ 
    227232                NUM_FILE_FIELDS = sizeof(file_format)/4; 
    …… 
    257262                           "FROM file" 
    258263                           "WHERE file_id = \'%i\'" 
    259                            "AND revision_id = (SELECT MAX(revision_id) FROM file WHERE file_id = 'some_id')", 
    260                            file_id); 
     264                           "AND revision_id = (SELECT MAX(revision_id) FROM file WHERE file_id = \'%i\')", 
     265                           file_id, file_id); 
    261266        PGresult *res=PQexec(pq_conn,pq_request); 
    262267 
    …… 
    331336        sprintf(pq_request,"SELECT directory_id " 
    332337                           "FROM directory " 
    333                            "WHERE directory_path = \'%s\' " 
    334                            "AND revision_id = (SELECT MAX(revision_id) FROM directory WHERE directory_path = 'some_path')", 
     338                           "WHERE directory_path = \'%s\'", 
    335339                           dir_name); 
    336340        PGresult *res=PQexec(pq_conn,pq_request); 
    …… 
    545549                                    "(stream_id, use_count, stream_name, stream) " 
    546550                                    "VALUES" 
    547                                     "%i, 0, \'%s\', \'%s\'", 
     551                                    "\'%i\', \'0\', \'%s\', \'%s\'", 
    548552                                    stream_id, stream_name, stream); 
    549553                PQfreemem(PQexec(pq_conn,pq_request)); 
    …… 
    587591                            "(file_uid, file_id, file_path, file_name, stream_id) " 
    588592                            "VALUES " 
    589                             "%i, %i, \'%s\', \'%s\', %i", 
     593                            "\'%i\', \'%i\', \'%s\', \'%s\', \'%i\'", 
    590594                            file_uid, file_id, dir_name, file_name, stream_id); 
    591595        PQfreemem(PQexec(pq_conn, pq_request)); 
    …… 
    599603        sprintf(pq_request, "SELECT * " 
    600604                            "FROM directory " 
    601                             "WHERE directory_id = %i", 
     605                            "WHERE directory_id = \'%i\'", 
    602606                            dir_id); 
    603607        PGresult *res=PQexec(pq_conn,pq_request); 
    …… 
    641645        sprintf(pq_request, "SELECT * " 
    642646                            "FROM file " 
    643                             "WHERE directory_id = %i", 
     647                            "WHERE directory_id = \'%i\'", 
    644648                            dir_id); 
    645649        PGresult *res=PQexec(pq_conn,pq_request); 
    …… 
    681685        char pq_request[BUFFER_SIZE]; 
    682686        sprintf(pq_request, "SELECT file_uid " 
    683                             "WHERE file_id = %i AND revision_id = %i", 
     687                            "WHERE file_id = \'%i\' AND revision_id = \'%i\'", 
    684688                            file_id, revision_id); 
    685689        PGresult *res = PQexec(pq_conn, pq_request); 
    …… 
    720724                            "file_name, directory_path, directory_id, data) " 
    721725                            "VALUES " 
    722                             "%i, %i, %i, %i, %i, %i, NOW, TRUE, %s, %s, %s", 
     726                            "\'%i\', \'%i\', \'%i\', \'%i\', \'%i\', \'%i\', \'NOW\', " 
     727                            "\'TRUE\', \'%s\', \'%s\', \'%s\'", 
    723728                            file_uid, file_id, file.revision_id, file.file_length, 
    724729                            parent_file_id, file.stream_id, file.file_name,  
    …… 
    729734        sprintf(pq_request, "UPDATE file " 
    730735                            "SET data = \'%s\' " 
    731                             "WHERE file_uid = %i", 
     736                            "WHERE file_uid = \'%i\'", 
    732737                            diff, parent_file_id); 
    733738        PQfreemem(PQexec(pq_conn, pq_request)); 
    …… 
    767772                            "file_name, directory_path, directory_id, data) " 
    768773                            "VALUES " 
    769                             "%i, %i, 0, %i, %i, %i, NOW, FALSE, %s, %s, %s", 
     774                            "\'%i\', \'%i\', \'0\', \'%i\', \'%i\', \'%i\', \'NOW\', " 
     775                            "\'FALSE\', \'%s\', \'%s\', \'%s\'", 
    770776                            file_uid, new_file_id, file.file_length, parent_file_id, 
    771777                            file.stream_id, new_file_name, new_dir_name,  
    …… 
    811817                            "file_name, directory_path, directory_id, data) " 
    812818                            "VALUES " 
    813                             "%i, %i, %i, %i, %i, %i, NOW, TRUE, %s, %s, %s", 
     819                            "\'%i\', \'%i\', \'%i\', \'%i\', \'%i\', \'%i\', \'NOW\', " 
     820                            "\'TRUE\', \'%s\', \'%s\', \'%s\'", 
    814821                            file_uid, file_id, file.revision_id, file.file_length, 
    815822                            parent_file_id, new_stream_id, file.file_name,  
    …… 
    820827        sprintf(pq_request, "UPDATE file " 
    821828                            "SET data = \'%s\' " 
    822                             "WHERE file_uid = %i", 
     829                            "WHERE file_uid = \'%i\'", 
    823830                            diff, parent_file_id); 
    824831        PQfreemem(PQexec(pq_conn, pq_request)); 
    …… 
    856863                            "file_name, directory_path, directory_id, data) " 
    857864                            "VALUES " 
    858                             "%i, %i, %i, %i, %i, %i, NOW, TRUE, %s, %s, %s", 
     865                            "\'%i\', \'%i\', \'%i\', \'%i\', \'%i\', \'%i\', \'NOW\', " 
     866                            "\'TRUE\', \'%s\', \'%s\', \'%s\'", 
    859867                            file_uid, file_id, file.revision_id, data_len, 
    860868                            parent_file_id, file.stream_id, file.file_name,  
    …… 
    865873        sprintf(pq_request, "UPDATE file " 
    866874                            "SET data = \'%s\' " 
    867                             "WHERE file_uid = %i", 
     875                            "WHERE file_uid = \'%i\'", 
    868876                            diff, parent_file_id); 
    869877        PQfreemem(PQexec(pq_conn, pq_request)); 

  • vowfsc/db.h

    r43 r44  
    156156 * non-zero on failture. 
    157157 */ 
    158 int db_init(); 
     158int db_init(char *host, int port, char *dbname, char *username, char *password); 
    159159int db_destroy(); 
    160160