php/lib/db.php

   1 <?php
   2 class db {
   3         function init() {
   4
   5                 $sql = 'CREATE TABLE sqlite_sequence(name,seq);';
   6                 $this->dbobject->query($sql);
   7
   8                 $sql = 'CREATE TABLE "hosts" ("ho_id" INTEGER PRIMARY KEY AUTOINCREMENT,"ho_sn_id" INTEGER,"ho_ip" TEXT,"ho_name" TEXT,"ho_desc" TEXT);';
   9                 $this->dbobject->query($sql);
  10
  11                 $sql = 'CREATE TABLE subnet ("sn_id" INTEGER PRIMARY KEY AUTOINCREMENT,"snid_id" INTEGER,"sn_ip" TEXT,"sn_mask" TEXT,"sn_name" TEXT, "sn_desc" TEXT);';
  12                 $this->dbobject->query($sql);
  13
  14                 $sql = 'CREATE TABLE supernet ("sn_id" INTEGER PRIMARY KEY AUTOINCREMENT,"sn_name" TEXT,"sn_ip" TEXT,"sn_mask" TEXT,"sn_desc" TEXT);';
  15                 $this->dbobject->query($sql);
  16         }
  17
  18         function connect() {
  19                 global $DB_URI;
  20
  21                 try {
  22                         $this->dbobject = new PDO("$DB_URI");
  23                 } catch(PDOException $exep) {
  24                         error_log("execpt on db open");
  25                 }
  26
  27                 if(!$this->dbobject->query("select * from hosts")) {
  28                         error_log("db open for init");
  29                         $this->init();
  30                 }
  31
  32         }
  33
  34         public $dbobject = "";
  35
  36         function dump() {
  37                 $sql = "select * from supernet";
  38                 $res = $this->dbobject->query($sql);
  39
  40                 foreach($res as $row) {
  41                         echo "sn:".$row["sn_id"].":".$row["sn_name"].":".$row["sn_ip"].":".$row["sn_mask"].":".$row["sn_desc"]."\n";
  42                 }
  43                 $sql = "select * from subnet";
  44                 $res = $this->dbobject->query($sql);
  45
  46                 foreach($res as $row) {
  47                         echo "sbn:".$row["sn_id"].":".$row["snid_id"].":".$row["sn_name"].":".$row["sn_ip"].":".$row["sn_mask"].":".$row["sn_desc"]."\n";
  48                 }
  49                 $sql = "select * from hosts";
  50                 $res = $this->dbobject->query($sql);
  51
  52                 foreach($res as $row) {
  53                         echo "hst:".$row["ho_id"].":".$row["ho_sn_id"].":".$row["ho_ip"].":".$row["ho_name"].":".$row["ho_desc"]."\n";
  54                 }
  55         }
  56
  57         function restore($restorefile) {
  58
  59         }
  60 }
  61
  62 ?>