topical media & game development
[] readme course(s) preface I 1 2 II 3 4 III 5 6 7 IV 8 9 10 V 11 12 afterthought(s) appendix reference(s) example(s) resource(s) _

talk show tell print

professional-php-11-class.pgsqlLoggerBackend.php / php



  <?php
  
  require_once('Logger/class.LoggerBackend.php');
  
  class pgsqlLoggerBackend extends LoggerBackend {
  
    private logLevel;
    private hConn;
    
    private table = 'logdata';
    private messageField = 'message';
    private logLevelField = 'loglevel';
    private timestampField = 'logdate';
    private moduleField = 'module';
    
    public function __construct(urlData) {
      global cfg;  //system configuration info array from some external file
      
      parent::__construct(urlData);
      
      this->logLevel = cfg['LOGGER_LEVEL'];
   
      host = urlData['host'];
      port = urlData['port'];
      user = urlData['user'];
      password = urlData['password'];
      arPath = explode('/', urlData['path']);
      database = arPath[1];
      
      if(!strlen(database)) {
        throw new Exception('pgsqlLoggerBackend: Invalid connection string.' . 
                            '  No database name was specified');
      }
      
      connStr = '';
      if(host) {
        connStr .= "host=host ";
      }
      
      if(port) {
        connStr .= "port=port ";    
      }
          
      if(user) {
        connStr .= "user=user ";
      }
  
      if(password) {
        connStr .= "password=password ";
      }
      
      connStr .= "dbname=database";
  
      //Suppress native errors.  We'll handle them with an exception
      this->hConn = pg_connect(connStr);
  
      if(! is_resource(this->hConn)) {
        throw new Exception("Unable to connect to the database using connStr");
      }
      
      //Take the query string in the form var=foo&bar=blah
      //and convert it to an array like
      // array('var' => 'foo', 'bar' => 'blah')
      //Be sure to convert urlencoded values
      queryData = urlData['query'];
      if(strlen(queryData)) {
        arTmpQuery = explode('&',queryData);
        
        arQuery = array();
        foreach(arTmpQuery as queryItem) {
          arQueryItem = explode('=', queryItem);
          arQuery[urldecode(arQueryItem[0])] = urldecode(arQueryItem[1]);
        }
      }
  
      //None of these items is mandatory.  The defaults are established in the
      //private member declarations at the top of the class.
      //These variables establish the name of the table and the names of the fields
      //within that table that store the various elements of the log entry.
      if(isset(arQuery['table'])) {
        this->table = arQuery['table'];
      }
  
      if(isset(arQuery['messageField'])) {
        this->messageField = arQuery['messageField'];
      }
     
      if(isset(arQuery['logLevelField'])) {
        this->logLevelField = arQuery['logLevelField'];
      }
      
      if(isset(arQuery['timestampField'])) {
        this->timestampField = arQuery['timestampField'];
      }
      
      if(isset(arQuery['moduleField'])) {
        this->logLevelField = arQuery['moduleField'];
      }
   
    }
    
     
    public function logMessage(msg, logLevel = LOGGER_INFO, module = null) {
  
      if(logLevel <= this->logLevel) {
        time = strftime('\%x \%X', time());
        
        strLogLevel = Logger::levelToString(logLevel);
        
        msg = pg_escape_string(msg);
        
        if(isset(module)) {
          module = "'" . pg_escape_string(module) . "'";
        } else {
          module = 'NULL';
        }
       
        arFields = array();
        arFields[this->messageField] = "'" . msg . "'";
        arFields[this->logLevelField] = logLevel;
        arFields[this->timestampField] = "'". strftime('\%x \%X', time()) . "'";
        arFields[this->moduleField] = module;
       
        sql = 'INSERT INTO ' . this->table;
        sql .= ' (' . join(', ', array_keys(arFields)) . ')';
        sql .= ' VALUES (' . join(', ', array_values(arFields)) . ')';
  
        pg_exec(this->hConn, sql);
        
      }
    }
  
  }
  ?>
[] readme course(s) preface I 1 2 II 3 4 III 5 6 7 IV 8 9 10 V 11 12 afterthought(s) appendix reference(s) example(s) resource(s) _

(C) Æliens 20/2/2008

You may not copy or print any of this material without explicit permission of the author or the publisher. In case of other copyright issues, contact the author.