|
@@ -1,6 +1,6 @@
|
1
|
1
|
<?php
|
2
|
2
|
interface DatabaseInterface {
|
3
|
|
- public function get_sql($name);
|
|
3
|
+ public function getSql($name);
|
4
|
4
|
public function connectDatabase($hostname,$username,$password,$database,$port,$socket,$charset);
|
5
|
5
|
public function query($sql,$params);
|
6
|
6
|
public function fetch_assoc($result);
|
|
@@ -77,7 +77,7 @@ class MySQL implements DatabaseInterface {
|
77
|
77
|
);
|
78
|
78
|
}
|
79
|
79
|
|
80
|
|
- public function get_sql($name) {
|
|
80
|
+ public function getSql($name) {
|
81
|
81
|
return isset($this->queries[$name])?$this->queries[$name]:false;
|
82
|
82
|
}
|
83
|
83
|
|
|
@@ -239,7 +239,7 @@ class PostgreSQL implements DatabaseInterface {
|
239
|
239
|
);
|
240
|
240
|
}
|
241
|
241
|
|
242
|
|
- public function get_sql($name) {
|
|
242
|
+ public function getSql($name) {
|
243
|
243
|
return isset($this->queries[$name])?$this->queries[$name]:false;
|
244
|
244
|
}
|
245
|
245
|
|
|
@@ -429,7 +429,7 @@ class SQLServer implements DatabaseInterface {
|
429
|
429
|
);
|
430
|
430
|
}
|
431
|
431
|
|
432
|
|
- public function get_sql($name) {
|
|
432
|
+ public function getSql($name) {
|
433
|
433
|
return isset($this->queries[$name])?$this->queries[$name]:false;
|
434
|
434
|
}
|
435
|
435
|
|
|
@@ -676,7 +676,7 @@ class PHP_CRUD_API {
|
676
|
676
|
$table_array = explode(',',$tables);
|
677
|
677
|
$table_list = array();
|
678
|
678
|
foreach ($table_array as $table) {
|
679
|
|
- if ($result = $this->db->query($this->db->get_sql('reflect_table'),array($table,$database))) {
|
|
679
|
+ if ($result = $this->db->query($this->db->getSql('reflect_table'),array($table,$database))) {
|
680
|
680
|
while ($row = $this->db->fetch_row($result)) $table_list[] = $row[0];
|
681
|
681
|
$this->db->close($result);
|
682
|
682
|
if ($action!='list') break;
|
|
@@ -739,7 +739,7 @@ class PHP_CRUD_API {
|
739
|
739
|
if (!$key) return false;
|
740
|
740
|
$count = 0;
|
741
|
741
|
$field = false;
|
742
|
|
- if ($result = $this->db->query($this->db->get_sql('reflect_pk'),array($tables[0],$database))) {
|
|
742
|
+ if ($result = $this->db->query($this->db->getSql('reflect_pk'),array($tables[0],$database))) {
|
743
|
743
|
while ($row = $this->db->fetch_row($result)) {
|
744
|
744
|
$count++;
|
745
|
745
|
$field = $row[0];
|
|
@@ -880,19 +880,19 @@ class PHP_CRUD_API {
|
880
|
880
|
$table0 = array_shift($tables);
|
881
|
881
|
$tableset[] = $table0;
|
882
|
882
|
|
883
|
|
- $result = $this->db->query($this->db->get_sql('reflect_belongs_to'),array($table0,$tables,$database,$database));
|
|
883
|
+ $result = $this->db->query($this->db->getSql('reflect_belongs_to'),array($table0,$tables,$database,$database));
|
884
|
884
|
while ($row = $this->db->fetch_row($result)) {
|
885
|
885
|
$collect[$row[0]][$row[1]]=array();
|
886
|
886
|
$select[$row[2]][$row[3]]=array($row[0],$row[1]);
|
887
|
887
|
if (!in_array($row[0],$tableset)) $tableset[] = $row[0];
|
888
|
888
|
}
|
889
|
|
- $result = $this->db->query($this->db->get_sql('reflect_has_many'),array($tables,$table0,$database,$database));
|
|
889
|
+ $result = $this->db->query($this->db->getSql('reflect_has_many'),array($tables,$table0,$database,$database));
|
890
|
890
|
while ($row = $this->db->fetch_row($result)) {
|
891
|
891
|
$collect[$row[2]][$row[3]]=array();
|
892
|
892
|
$select[$row[0]][$row[1]]=array($row[2],$row[3]);
|
893
|
893
|
if (!in_array($row[2],$tableset)) $tableset[] = $row[2];
|
894
|
894
|
}
|
895
|
|
- $result = $this->db->query($this->db->get_sql('reflect_habtm'),array($database,$database,$database,$database,$table0,$tables));
|
|
895
|
+ $result = $this->db->query($this->db->getSql('reflect_habtm'),array($database,$database,$database,$database,$table0,$tables));
|
896
|
896
|
while ($row = $this->db->fetch_row($result)) {
|
897
|
897
|
$collect[$row[2]][$row[3]]=array();
|
898
|
898
|
$select[$row[0]][$row[1]]=array($row[2],$row[3]);
|