Ignore:
Timestamp:
23/04/08 09:56:50 (12 years ago)
Author:
cbyrom
Message:

Add default logging support + create new version of ingest script, removing
all traces of the eXist DB + improve documentation and output.

File:
1 edited

Legend:

Unmodified
Added
Removed
  • TI01-discovery/branches/ingestAutomation-upgrade/OAIBatch/db_funcs.py

    r3797 r3817  
    33# functions for use with NDG discovery postgres db 
    44 
    5 import pgdb 
     5import pgdb, logging 
    66 
    77def db_connect(): 
    8         # Open a Postgres database connection 
     8        ''' 
     9        Open a Postgres database connection 
     10        ''' 
    911        DATABASE = 'test' 
    1012        HOST     = 'localhost' 
     
    1214        PW       = 'pass01word' 
    1315        SCHEMA   = 'public' 
    14 #       DATABASE = 'xxxx' 
    15 #       HOST     = 'xxx.xxx.uk' 
    16 #       USER     = 'xxx' 
    17 #       PW       = 'xxxxxxx' 
    18 #       SCHEMA   = 'xxx' 
     16        #       DATABASE = 'xxxx' 
     17        #       HOST     = 'xxx.xxx.uk' 
     18        #       USER     = 'xxx' 
     19        #       PW       = 'xxxxxxx' 
     20        #       SCHEMA   = 'xxx' 
     21        logging.info("Setting up connection to DB: " + DATABASE + " on " + HOST) 
    1922        connection_string = HOST + ':' + DATABASE + ':' + USER + ':' + PW 
    2023        connection = pgdb.connect(connection_string) 
    21         return connection 
     24        logging.info("DB connection established") 
     25        return connection 
    2226 
    2327 
     
    2832        @param sqlCmd: a SQL command to execute with the postgres connection   
    2933        ''' 
    30         print "Running SQL command: %s" %sqlCmd 
     34        logging.info("Running SQL command") 
     35        logging.debug("Actual command: %s" %sqlCmd) 
    3136        cursor = connection.cursor() 
    3237        try: 
    3338            cursor.execute(sqlCmd) 
    3439        except: 
    35             print "Error: database error %s %s" %(sys.exc_type, sys.exc_value) 
     40            sys.exit("Error: database error %s %s" %(sys.exc_type, sys.exc_value)) 
    3641        connection.commit() 
     42        logging.info("SQL command completed successfully") 
    3743        return cursor.fetchall() 
    3844 
Note: See TracChangeset for help on using the changeset viewer.