lib/database.php

   1 <?php
   2         define('WARAQ_ROOT', '..');
   3         require_once WARAQ_ROOT .'/ini.php';
   4
   5         require_once "code.php";
   6
   7         class BDB extends PDO
   8         {
   9                 var $type, $name, $host, $user, $password;
  10
  11                 function __construct($dsn, $username = NULL, $password = NULL)
  12                 {
  13                         $this->user     = $username;
  14                         $this->password = $password;
  15                         if (is_array($dsn)) {
  16                                 $dbconfig = $dsn;
  17                                 $this->type     = $dbconfig['type'];
  18                                 $this->name     = $dbconfig['name'];
  19                                 $this->host     = $dbconfig['host'];
  20                                 $dsn = $this->getDsn();
  21                         }
  22                         parent::__construct($dsn,$username, $password);
  23                 }
  24
  25                 function getDsn()
  26                 {
  27                         $dsn = $this->type .':';
  28                         if ("sqlite" == $this->type or "sqlite2" == $this->type) {
  29                                 $dsn .= $this->name;
  30                         } else {
  31                                 $dsn .= 'host='. $this->host;
  32                                 $dsn .= ';dbname='. $this->name;
  33                         }
  34                         return $dsn;
  35                 }
  36
  37                 function httpGet($localResource)
  38                 {
  39                         $queryString  = "dbt=". $this->type;
  40                         $queryString .= "&dbn=". $this->name;
  41                         $queryString .= "&dbh=". $this->host;
  42                         $queryString .= "&dbu=". $this->user;
  43                         $queryString .= "&dbp=". $this->password;
  44                         return file_get_contents($localResource->url .'?'. $queryString);
  45                 }
  46
  47                 function listTables()
  48                 {
  49                         $dbType = $this->getAttribute(PDO::ATTR_DRIVER_NAME);
  50                         if ('sqlite' == $dbType || 'sqlite2' == $dbType) {
  51                                 $query = "select name from sqlite_master where type='table'";
  52                         } else {
  53                                 $query = "show tables";
  54                         }
  55                         $result = $this->query($query);
  56                         $tables = array();
  57                         foreach ($result as $r) {
  58                                 $tables []= new Table($r[0]);
  59                         }
  60
  61                         return $tables;
  62                 }
  63         }
  64
  65         class Table
  66         {
  67                 var $name;
  68                 var $columns;
  69
  70                 function __construct($name, $columns = array())
  71                 {
  72                         $this->name = $name;
  73                         $this->columns = $columns;
  74                 }
  75
  76                 function loadColumns($db)
  77                 {
  78                         $this->columns = array();
  79                         $table = $this->name;
  80                         $dbType = $db->getAttribute(PDO::ATTR_DRIVER_NAME);
  81                         if ('sqlite' == $dbType || 'sqlite2' == $dbType) {
  82                                 $query = "select sql from sqlite_master where type='table' and name='$table'";
  83                                 $row = $db->query($query)->fetch();
  84                                 $createQuery = new SqlCode($row['sql']);
  85                                 $this->columns = $createQuery->extractColumns();
  86                         } else {
  87                                 $query = "show columns from $table";
  88                                 $result = $db->query($query);
  89                                 foreach ($result as $column) {
  90                                         $this->columns []= new Column($column['Field'], $column['Type']);
  91                                 }
  92                         }
  93
  94                         return $this->columns;
  95                 }
  96         }
  97
  98
  99         class Column
 100         {
 101                 var $name;
 102                 var $type;
 103
 104                 function __construct($name, $type = NULL)
 105                 {
 106                         $this->name = $name;
 107                         $this->type = $type;
 108                 }
 109         }
 110
 111 function columnNames($row)
 112         $names = array();
 113         if (is_array($row)) $names = array_keys($row);
 114         return $names;
 115 }
 116