lib/database.php

   1 <?php
   2         define('WARAQ_ROOT', '..');
   3         require_once WARAQ_ROOT .'/ini.php';
   4
   5         require_once "DB.php";
   6
   7         class Query
   8         {
   9                 var $string;
  10                 var $tables;
  11                 var $conditions;
  12                 var $data;
  13
  14                 function Query()
  15                 {
  16                 }
  17
  18                 function db($dsn)
  19                 {
  20                         static $db;
  21
  22                         $db = DB::Connect($dsn);
  23                         $this->data = $db->getAll($this->string);
  24                 }
  25
  26                 function select()
  27                 {
  28                         $this->string = "select";
  29                 }
  30
  31                 function from($tables)
  32                 {
  33                         $this->tables = $tables;
  34                         $this->string .= " ". implode(',', $tables) ." ";
  35                 }
  36
  37                 function where($conditions)
  38                 {
  39                         $this->conditions = $conditions;
  40                         foreach ($conditions as $column => $value) {
  41                         }
  42                 }
  43         }
  44
  45         class DataBase extends DB
  46         {
  47                 var $db;
  48
  49                 function DataBase($dsn)
  50                 {
  51                         $this->db = DB::Connect($dsn);
  52                 }
  53
  54                 function insert($table, $data)
  55                 {
  56                         $query = "insert $table set ". DataBase::serialize_data($data);
  57                         return $this->query($query);
  58                 }
  59
  60                 function select($data)
  61                 {
  62                         $tables = DataBase::extract_tables($data);
  63                         $query  = "select * from ". implode(',', $tables);
  64                         $query .= " where ". DataBase::serialize_data($data, 'and');
  65                         return $this->query($query);
  66                 }
  67
  68                 function serialize_data($data, $separator = ',')
  69                 {
  70                         $tuples = array();
  71                         foreach ($data as $key => $value) {
  72                                 $tuples[] = " $key='$value' ";
  73                         }
  74                         return implode(" $separator ", $tuples);
  75                 }
  76
  77                 function extract_tables($data)
  78                 {
  79                         $tables = array();
  80                         foreach (array_keys($data) as $column) {
  81                                 list($tableName, $columnName) = split('.', $column);
  82                                 $tables[] = $tableName;
  83                         }
  84                         return $tables;
  85                 }
  86         }