<?php
/**
* AbstractDatabaseManager
* 番組のクラスはこれをオーバーライドして利用します。一般DB用。
* $Id: AbstractDatabaseManager.inc,v 1.1 2015/10/08 11:18:56 wanggb Exp $
* @author iimuro
* @access public
* @package jp.aimslib2.database
*/
class AbstractDatabaseManager{
/**
* 使用するデータベースの種類。
* init時にセットする。
* 指定がない場合はPostgres?
*/
public $dbtype = null;
/**
* 接続する先
*/
public $adaptor;
/**
* SQL文生成
*/
public $builder;
/**
* 型変換等データベースの差異があるもの
*/
public $util;
/**
* 接続に必要な情報でクラスを初期化します。
* @param String データベース名
* @param String データベースユーザー名
* @param String 接続パスワード
* @param String データベースホスト名。自サーバー内ならlocalhost。
* @param String ポート番号
* @param String データベース種類。デフォルトは"PostgreSQL"
*/
public function init($db_name, $user, $pass, $host, $port, $dbtype = "PostgreSQL"){
$this->dbtype = $dbtype;
if (strtolower($dbtype) == "postgresql") {
// 接続情報をアダプターに設定。以降、接続要求はこれらの値を利用。
$this->adaptor = new PostgresDatabaseAdaptor();
$this->adaptor->init($host, $port, $db_name, $user, $pass);
// SQL文はPostgres用
$this->builder = new PostgresSQLBuilder();
// 型、関数もPostgres用→executeQueryを使うときの文章生成に利用。
$this->util = new PostgresUtil();
} elseif (strtolower($dbtype) == "mysql") {
// 接続情報をアダプターに設定。以降、接続要求はこれらの値を利用。
$this->adaptor = new MySQLDatabaseAdaptor();
$this->adaptor->init($host, $port, $db_name, $user, $pass);
// SQL文はMySQL用
$this->builder = new MySQLSQLBuilder();
// 型、関数もMySQL用→executeQueryを使うときの文章生成に利用。
//$this->util = new MySQLUtil();
} else {
ErrorLogger::doOutput("Unsupported Databse Type!");
}
}
/**
* @abstract
*/
public function getConnection(){
return null;
}
/**
* SQL文を実行します。
*/
public function executeQuery($sql){
//echo "<br>".$sql;
return $this->adaptor->db_exec($sql);
}
/**
*
*/
public function db_copy_from($table, $data, $delimiter = "\t"){
return $this->adaptor->db_copy_from($table, $data, $delimiter);
}
/**
*
*/
public function doDelect($table, $w_param){
$option = "";
if($w_param != null){
$option = " WHERE " . $this->builder->createOptionCondition($w_param);
}
$sql = "DELETE FROM " . $table . $option . ";";
$this->executeQuery($sql);
}
/**
*
*/
public function doSelect($table, $w_param, $orderkey = null, $direction = "ASC", $offset = null, $limit = null, $selectkey = "*"){
$option = "";
if($w_param != null){
$option = " WHERE " . $this->builder->createOptionCondition($w_param);
}
$order = "";
if($orderkey != null){
$order .= " ORDER BY " . $orderkey . " " . $direction;
}
$subquery = $this->builder->createSubQuery($offset, $limit);
$sql = "SELECT ".$selectkey." FROM " . $table . $option . $order . $subquery . ";";
$rowset = $this->executeQuery($sql);
return $rowset;
}
/**
*
*/
public function doInsert($table, $v_param){
$sql1 = "INSERT INTO " . $table . " ";
$sql1 .= $this->builder->createInsertValueOption($v_param);
if (strtolower($this->dbtype) == "postgresql") {
// aimswebのシステムは、常にidをsequenceとして持つことを想定
$sql1 .= " returning id";
}
//return $this->executeQuery($sql1);
$tmp = $this->executeQuery($sql1);
if (isset($tmp[0]["id"])) {
return $tmp[0]["id"];
}
return $tmp;
}
/**
*
*/
public function doInsertAndReturn($table, $v_param){
$result = null;
if (strtolower($this->dbtype) == "postgresql") {
$sql1 = "INSERT INTO " . $table . " ";
$sql1 .= $this->builder->createInsertValueOption($v_param);
$sql1 .= " returning *";
$result = $this->executeQuery($sql1);
} elseif (strtolower($this->dbtype) == "mysql") {
$sql1 = "INSERT INTO " . $table . " ";
$sql1 .= $this->builder->createInsertValueOption($v_param);
$this->executeQuery($sql1);
$sql2 = "select last_insert_id() as id";
$tmp = $this->executeQuery($sql2);
if (isset($tmp[0]["id"])) {
$w_param = array();
$w_param["id"] = $tmp[0]["id"];
$result = $this->doSelect($table, $w_param, null, null, 0, 1);
} else {
// エラー？
error_log("error: id not found at select last_insert_id()", 0);
return null;
}
} else {
ErrorLogger::doOutput("Unsupported Databse Type!");
}
return $result;
}
/**
*
*/
public function doUpdate($table, $w_param, $v_param){
$set_param = $this->builder->createSetValueOption($v_param);
if(count($w_param) > 0){
$where_option = $this->builder->createOptionCondition($w_param);
$sql = "UPDATE " . $table . " SET $set_param WHERE $where_option";
}else{
$sql = "UPDATE " . $table . " SET $set_param";
}
$this->executeQuery($sql);
}
/**
* 明示的にトランザクションを管理したいときに利用します。
* トランザクション開始。
*/
public function doBegin(){
$sql = "BEGIN";
$this->executeQuery($sql);
}
/**
* 明示的にトランザクションを管理したいときに利用します。
* トランザクション終了。
*/
public function doEnd(){
$sql = "COMMIT";
$this->executeQuery($sql);
}
/**
* 明示的にトランザクションを管理したいときに利用します。
* トランザクション破棄して終了。
*/
public function doRollback(){
$sql = "ROLLBACK";
$this->executeQuery($sql);
}
/**
* resultset を一括挿入
*/
public function db_copy_resultset($table, $column_name, $resultset, $delimiter = "\t"){
$data = array();
foreach($resultset as $row){
$line = "";
for($i=0; $i < count($column_name); $i++) {
if(isset($row[$column_name[$i]])){
$line .= $row[$column_name[$i]];
}else{
$line .= "\N";
}
if($i < count($column_name) - 1){
$line .= $delimiter;
}
}
$line .= "\n";
array_push($data, $line);
}
array_push($data, "\\.\n");
return $this->db_copy_from($table, $data, $delimiter);
}
/**
* ラージオブジェクトを保存します。OIDが指定されない場合は新規に作成します。
* この処理を行う前にはかならずトランザク ションブロックの中に括る必要があります。
* @access public
* @param string $data ラージオブジェクトバイナリデータ
* @param int $oid ラージオブジェクトOID
* @return int ラージオブジェクトOID。失敗時はnull。
*/
public function writeLargeObject($data, $oid = null) {
return $this->adaptor->writeLargeObject($data, $oid);
}
/**
* ラージオブジェクトを読み出します。
* この処理を行う前にはかならずトランザク ションブロックの中に括る必要があります。
* @access public
* @param int $oid ラージオブジェクトOID
* @return int ラージオブジェクトバイナリデータ。失敗時はnull。
*/
public function readLargeObject($oid) {
return $this->adaptor->readLargeObject($oid);
}
/**
* ラージオブジェクトを削除します。
* この処理を行う前にはかならずトランザク ションブロックの中に括る必要があります。
* @access public
* @param int $oid ラージオブジェクトOID
* @return boolean 成功時true
*/
public function deleteLargeObject($oid = null) {
return $this->adaptor->deleteLargeObject($oid);
}
/**
* データベースのデータの変換や定型文の生成などのUtilクラスを取得します。
*/
public function getUtility() {
return $this->util;
}
}
?>