以前との改良点
１. DB接続の設定をiniファイルからdefineに変更
２. dboクラスは拡張拡張可能になった。
phpのinclude_path設定に存在するディレクトリの中のDBOディレクトリ以下にあるファイルを検索する
ファイルの命名規則はクラス名と同じファイル名+拡張子がphpであること
３. 検索フィールド名のデミリタが変更可能
使用例：
$table_name = 't_foobar'; //DBに存在するテーブル名 or 拡張クラス名 //テーブルをコントロールするDBOクラスを取得する $dbo = pdbo::Factory($table_name); //検索 $condition = array( 'foobar_name->eq' => 'foobar', 'foobar_year' => 10, ); $rows = $dbo->getAllBySearch( $condition ); //検索結果が配列で取得できる
クラス定義：
//検索フィールド名のデミリタ
define( 'PDBO_DEMILT', '->' );
//PDBの接続設定
define('PDO_DSN_STRING','');
define('PDO_DSN_USERNAME','');
define('PDO_DSN_PASSWORD','');
// PDOを利用したデータベースクラス
class pdbo{
private static $pdo;
private function __construct(){
}
public function Factory( $table ){
if( is_null( pdbo::$pdo ) ){
try{
pdbo::$pdo = new PDO(
PDBO_DSN_STRING,
DBO_DSN_USERNAME,
DBO_DSN_PASSWORD,
array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8")
);
} catch( PDOException $e ){
echo $e->GetMessage();
throw new Exception( $e->getMessage() );
}
}
$tmp = explode(':', get_include_path() );
foreach( $tmp as $val ){
$tmp = "{$val}/DBO/{$table}.php";
if( file_exists($tmp) ){
include_once $tmp;
return new $table( pdbo::$pdo, '', '' );
}
}
return new pdbo_if( pdbo::$pdo, '', $table );
}
}
class dbo{
protected $dbo;
protected $db_name;
protected $table_name;
protected $fields;
protected $error_message;
protected $query_log = array();
public function __construct( &$pdbo, $db, $table ){
$this->dbo = $pdbo;
$this->db_name = $db;
$this->table_name = $table;
if( strlen($this->table_name) == 0 ){
$this->table_name = $this->_tablename;
$table = $this->_tablename;
}
//テーブル情報取得
try{
$ret = $pdbo->query( 'DESCRIBE '.$table );
} catch( PDOException $e ){
$this->error_message = $e->getMessage();
throw new Exception( $this->error_message );
}
$tmp = $ret->fetchAll( PDO::FETCH_ASSOC );
if( !$tmp ) echo $table;
foreach( $tmp as $node ){
$type = $this->getType( $node['Type'] );
$this->fields[$node['Field']]['type']= $type['type'];
$this->fields[$node['Field']]['size']= $type['size'];
$this->fields[$node['Field']]['option']= $type['option'];
$this->fields[$node['Field']]['null']= $node['Null'];
$this->fields[$node['Field']]['key'] = $node['Key'];
}
}
public function pdbo_if( &$pdo, $db, $table){
$this->__construct( $pdo, $db, $table );
}
public function DumpQuery(){
print_r( $this->query_log );
}
public function TraceDump(){ return $this->DumpQuery(); }
public function begin(){
$this->dbo->beginTransaction();
}
public function commit(){
$this->dbo->commit();
}
public function rollback(){
$this->dbo->rollback();
}
public function getLastInsertID(){
return $this->dbo->lastInsertId();
}
/**
* 一行だけレコードを取得する
* $flagがtrueの時、条件配列にプライマリキーが存在しない場合エラーに
* なります
* @param array $condition 条件配列
* @param array $sort ソート配列
* @param bool $flag プライマリキー存在チェック
* @param array $option オプション
*/
public function getOnce(
$condition, $order = array(), $flag = true, $option = array()
){
$table = $this->table_name;
$dbo =& $this->dbo;
if( $flag ){
//プライマリーキーの存在チェック
$primary = $this->getPrimary();
$keys = array_keys( $condition );
foreach( $primary as $name ){
if( !in_array( $name, $keys ) ){
throw new Exception('プライマリーキーが設定されていません');
}
}
}
//フィールド
$fields = array();
if( isset( $option['fields'] ) ) $fields = $option['fields'];
//フィールド構築
if( count( $fields ) ){
$fields = $this->makefields( $fields );
$fields = implode( ',', $fields );
} else {
$fields = '*';
}
//検索条件生成
$ret = null;
try{
$where = $this->makeWhere( $condition );
$_order = $this->makeOrder( $order );
$_groupby= '';
if( isset( $option['groupby'] ) && count( $option['groupby'] ) ){
$_groupby = ' GROUP BY '.join( ',', $option['groupby'] );
}
$sql = "SELECT {$fields} FROM {$table}";
if( strlen( $where ) > 0 ) $sql .= $where;
if( strlen( $_order) > 0 ) $sql .= $_order;
if( strlen( $_groupby) > 0 ) $sql .= $_groupby;
$this->query_log[] = $sql;
$ret = $dbo->query( $sql );
} catch( PDOException $e ){
$this->error_message = $e->getMessage();
throw new Exception( $this->error_message );
}
//エラー処理
if( $ret === false ) throw new Exception( "query error: {$sql}");
//複数行検出
if( $ret->rowCount() != 1 ) return false;
return $ret->fetch(PDO::FETCH_ASSOC);
}
/**
*
*/
public function getRowBySearch(
$condition, $order = array(), $flag = true, $option = array()
){
return $this->getOnce( $condition, $order, $flag, $option );
}
public function getRow(
$condition, $order = array(), $flag = true, $option = array()
){
return $this->getOnce( $condition, $order, $flag, $option );
}
/**
* 条件に一致するレコードを全て取得する
* $flagがtrueの時、条件配列にプライマリキーが存在しない場合エラーに
* なります
* @param array $condition 条件配列
* @param bool $flag プライマリキー存在チェック
*/
public function getAllBySearch(
$condition = array(), $order = array(), $option = array()
){
$table = $this->table_name;
$dbo =& $this->dbo;
//フィールド
$fields = array();
if( isset( $option['fields'] ) ) $fields = $option['fields'];
//フィールド構築
if( count( $fields ) ){
$fields = $this->makefields( $fields );
$fields = implode( ',', $fields );
} else {
$fields = '*';
}
//検索条件生成
$ret = null;
try{
$where = $this->makeWhere( $condition );
$_order = $this->makeOrder( $order );
$sql = "SELECT {$fields} FROM {$table}";
$sql .= $where;
$sql .= $_order;
$this->query_log[] = $sql;
$ret = $dbo->query( $sql );
} catch( PDOException $e ){
$this->error_message = $e->getMessage();
throw new Exception( $this->error_message );
}
//エラー処理
if( $ret === false ) throw new Exception( "query error: {$sql}");
return $ret->fetchAll(PDO::FETCH_ASSOC);
}
public function getAllBySearchWithPager(
&$pager, $condition, $order=array(), $option=array()
){
unset($condition['limit'] );
unset($condition['sort_number']);
unset($condition['display_number']);
if( isset($condition['from']) ) {
$pager['now'] = $condition['from'] / $pager['limit'] + 1;
}
unset($condition['from']);
unset($condition['numrows']);
return $this->getAllPager( $condition, $order, $pager, $option );
}
/**
* 条件に一致するレコードを全て取得する
* また、ページャー情報を生成する
* $flagがtrueの時、条件配列にプライマリキーが存在しない場合エラーに
* なります
* @param array $condition 条件配列
* @param bool $flag プライマリキー存在チェック
*/
public function getAllPager(
$condition = array(), $order = array(), &$page, $option = array()
){
$table = $this->table_name;
$dbo =& $this->dbo;
//フィールド
$fields = array();
if( isset( $option['fields'] ) ) $fields = $option['fields'];
//フィールド構築
if( count( $fields ) ){
$fields = $this->makefields( $fields );
$fields = implode( ',', $fields );
} else {
$fields = '*';
}
//検索条件生成
$res = null;
try{
$where = $this->makeWhere( $condition );
$_order = $this->makeOrder( $order );
$sql = "SELECT {$fields} FROM {$table}";
$sql .= $where;
$sql .= $_order;
$this->query_log[] = $sql;
$res = $dbo->query( $sql );
/*
$res = $dbo->prepare(
$sql, array(PDO::ATTR_CURSOR=>PDO::CURSOR_SCROLL)
);
*/
$res->execute();
} catch( PDOException $e ){
$this->error_message = $e->getMessage();
throw new Exception( $this->error_message );
}
//エラー処理
if( $res === false ) throw new Exception( "query error: {$sql}");
// ページャ処理
if( !isset( $page['now'] ) ) {
if( isset( $page['from'] ) ){
if( $page['from'] == 0 ) $page['now'] = 1;
else $page['now'] = ceil( $page['from'] / $page['limit'] );
} else {
$page['now'] = 1;
}
}
$page['rowCount'] = $res->rowCount();
$page['pageMax'] = ceil( $page['rowCount'] / $page['limit'] );
$page['start'] = ( $page['now'] - 1 ) * $page['limit'];
if( $page['start'] < 1 ) $page['start'] = 0; $page['end'] = $page['now'] * $page['limit']; if( $page['end'] > $page['rowCount'] ) $page['end'] = $page['rowCount'];
// レコード取得
$ret = array();
$all = $res->fetchAll(PDO::FETCH_ASSOC);
if( $page['rowCount'] > 0 ){
for( $n = $page['start']; $n < $page['end']; $n ++ ){
if( !isset($all[$n]) ) break;
$ret[] = $all[$n];
/*
echo "n: {$n}
$n";
$tmp = $res->fetch( PDO::FETCH_ASSOC, PDO::FETCH_ORI_ABS, $n );
if(!$tmp) break;
$ret[] = $tmp;
*/
}
}
return $ret;
}
/**
* ページャ情報を編集する
*/
public function fixPager( $pager, $option = array() ){
/*
* numrows
* allnumrows
* to
* firstpage
* prev
* pages
* next
* lastpage
*/
$tmp = $pager;
$pager = array(
'numrows' => $tmp['rowCount'],
'allnumrows'=> $tmp['rowCount'],
'from' => $tmp['start'] + 1,
'to' => $tmp['end'],
'firstpage' => '',
'prev' => '',
'next' => '',
'lastpage' => '',
'pages' => array(),
'current' => $tmp['now'],
);
//リンク生成
$myFile = basename( $_SERVER['SCRIPT_NAME'] );
$opt = '';
if( count($option) ) {
$tt = array();
foreach( $option as $key => $val) $tt[] = "{$key}={$val}";
$opt = '&'.implode('&',$tt);
}
if( $tmp['pageMax'] == 1 ){
$pager['firstpage'] = null;
$pager['prev'] = null;
}
if( $tmp['pageMax'] == $tmp['now'] || $tmp['pageMax'] == 1){
$pager['next'] = null;
$pager['lastpage'] = null;
}
for( $n = 1; $n 1 ){
$pager['prev'] = $pager['pages'][$pager['current']-1];
$pager['firstpage'] = $pager['pages'][1];
}
if( $tmp['pageMax'] > 1 && $pager['current'] < $tmp['pageMax']){ $pager['next'] = $pager['pages'][$pager['current']+1]; $pager['lastpage'] = $pager['pages'][$tmp['pageMax']]; } return $pager; } /** * 唯一のレコード更新 */ public function updateOnce( $data ){ $now = time(); $table = $this->table_name;
$dbo =& $this->dbo;
$fields =& $this->fields;
//更新データ
$up_data = array();
//条件データ
$condition = array();
foreach( $data as $name => $val ){
//if( !in_array( $name, array_keys($fields) ) ) continue;
list( $nm ) = $this->getfieldName( $name );
if( $fields[$nm]['key'] == 'PRI' ){
$condition[$name] = $val;
} else {
$up_data[$name] = $val;
}
}
if( count($condition) == 0) {
throw new Exception(
"updateOnce関数の引数にプライマリキーがありませんでした。"
);
}
//更新日
if( array_key_exists( 'update_datetime', $this->fields ) &&
!array_key_exists( 'update_datetime', $data )
){
$data['update_datetime'] = $now;
}
return $this->update( $up_data, $condition );
}
/**
* 複数更新
*/
public function update( $data, $condition = array() ){
$now = time();
$table = $this->table_name;
$dbo =& $this->dbo;
$fields =& $this->fields;
$node = array();
//更新日
if( array_key_exists( 'update_datetime', $this->fields ) &&
!array_key_exists( 'update_datetime', $data )
){
$data['update_datetime'] = $now;
}
$upd_data = array();
foreach( $data as $key => $val ) {
if( !is_array( $val ) ) $val = addslashes( $val );
$option = '';
//オプション検出
if( strpos( $key, PDBO_DEMILT ) !== false ){
$tmp = $key;
$tmp = explode( PDBO_DEMILT, $tmp );
$key = $tmp[0];
$option = $tmp[1];
//存在しないキーはスキップ
if( !array_key_exists( $key, $fields ) ) continue;
if( !is_array( $val ) ){
//文字列 日付型 の場合の処理
if( $this->isString( $fields[$key]['type'] ) ||
$this->isDate( $fields[$key]['type'] )
) {
$val = "'{$val}'";
} else {
//セカンドオプションがある時
if( isset( $tmp[2] ) ){
//セカンドオプションが文字型の時
if( $tmp[2] == 'STR' ) $val = "'{$val}'";
}
}
}
$upd_data[$key] = $this->CombineValue( $key, $option, $val);
} else {
if( !array_key_exists( $key, $fields ) ) continue;
//文字列 日付型 の場合の処理
if( $this->isString( $fields[$key]['type'] ) ) $val="'{$val}'";
if($this->isDate( $fields[$key]['type'] )
) {
$val = "'".date('Y-m-d H:i:s', $val)."'";
} else {
//セカンドオプションがある時
if( isset( $tmp[2] ) ){
//セカンドオプションが文字型の時
if( $tmp[2] == 'STR' ) $val = "'{$val}'";
}
}
$upd_data[$key] = $val;
}
}
try{
$where = $this->makeWhere( $condition );
$node = array();
foreach( $upd_data as $name => $val){
$node[] = "{$name} = {$val}";
}
$sql = "UPDATE {$table} SET ".implode( ' , ', $node )." {$where}";
$this->query_log[] = $sql;
$dbo->query( $sql );
} catch( Exception $e){
echo $e->getMessage();
return false;
}
return true;
}
/**
* 一行だけレコードを取得する
* $flagがtrueの時、条件配列にプライマリキーが存在しない場合エラーに
* なります
* @param array $data 登録情報
* @param bool $flag プライマリキー存在チェック
*/
public function insert( $data, $flag = true ){
$now = time();
if( count( $data ) == 0 ) return false;
$fields =& $this->fields;
//登録日
if( array_key_exists( 'regist_datetime', $this->fields ) &&
!array_key_exists( 'regist_datetime', $data )
){
$data['regist_datetime'] = $now;
}
//更新日
if( array_key_exists( 'update_datetime', $this->fields ) &&
!array_key_exists( 'update_datetime', $data )
){
$data['update_datetime'] = $now;
}
$tmp = $data;
/*
//文字列次処理
foreach( $data as $name => $val ){
//文字列時にクォートをつける
if( $this->isString($fields[$name]['type']) ){
$val = "'".addslashes($val)."'";
}
//日付時にクォートをつける
if( $this->isDate($fields[$name]['type']) ) {
if( is_int( $val ) ){
$val = date( 'Y-m-d H:i:s', $val );
}
$val = "'".addslashes($val)."'";
}
$data[$name] = $val;
}
*/
$inst_data = array();
foreach( $data as $key => $val ) {
if( !is_array( $val ) ) $val = addslashes( $val );
$option = '';
//オプション検出
if( strpos( $key, PDBO_DEMILT ) !== false ){
$tmp = $key;
$tmp = explode( PDBO_DEMILT, $tmp );
$key = $tmp[0];
$option = $tmp[1];
//存在しないキーはスキップ
if( !array_key_exists( $key, $fields ) ) continue;
if( !is_array( $val ) ){
//文字列 日付型 の場合の処理
if( $this->isString( $fields[$key]['type'] ) ||
$this->isDate( $fields[$key]['type'] )
) {
$val = "'{$val}'";
} else {
//セカンドオプションがある時
if( isset( $tmp[2] ) ){
//セカンドオプションが文字型の時
if( $tmp[2] == 'STR' ) $val = "'{$val}'";
}
}
}
$inst_data[$key] = $this->CombineValue( $key, $option, $val);
} else {
if( !array_key_exists( $key, $fields ) ) continue;
//文字列 日付型 の場合の処理
if( $this->isString( $fields[$key]['type'] ) ) $val="'{$val}'";
if($this->isDate( $fields[$key]['type'] )
) {
$val = "'".date('Y-m-d H:i:s', $val)."'";
} else {
//セカンドオプションがある時
if( isset( $tmp[2] ) ){
//セカンドオプションが文字型の時
if( $tmp[2] == 'STR' ) $val = "'{$val}'";
}
}
$inst_data[$key] = $val;
}
}
//インサートチェック
if(($name=pdbo_if::existsfield($inst_data,$this->getNotNull()))!==true){
throw new Exception(
"{$name}はnot nullのフィールドですが、存在していませんでした。"
);
}
$sql = "INSERT INTO {$this->table_name} ( ".
implode( ' , ', array_keys($inst_data) )." ) VALUES ( ";
$sql .= implode( ', ', $inst_data )." ); ";
try{
$this->query_log[] = $sql;
$ret = $this->dbo->query( $sql );
} catch( PDOException $e ) {
throw new Exception( 'Insert Error:'.$e->getMessage() );
}
if( $ret === false ){
throw new Exception( 'Insert Error: '.$sql );
}
return true;
}
/**
* 一件削除
*/
public function deleteOnce( $condition = array() ){
}
/**
* 条件削除
*/
public function deleteSearch( $condition ){
//if( count( $condition ) == 0 ) return false;
$sql = "DELETE FROM {$this->table_name} ".$this->makeWhere($condition);
try{
$this->query_log[] = $sql;
$ret = $this->dbo->query( $sql );
} catch( PDOException $e ) {
throw new Exception( 'Insert Error:'.$e->getMessage() );
}
return true;
}
public function deleteByArray($ids){
$condition = array();
foreach( $ids as $key => $val ){
$condition[$key.'->in'] = $val;
}
return $this->deleteSearch( $condition );
}
/**
* Where句の生成
*/
private function makeWhere( $condition ){
if( count( $condition ) == 0 ) return '';
$fields = $this->fields;
$where = array();
foreach( $condition as $key => $val ){
if( !$val ) continue;
if( is_string($val) && strlen( trim($val) ) == 0 ) continue;
if( is_array($val) && count( $val ) == 0 ) continue;
if( !is_array( $val ) ) $val = addslashes( $val );
$option = '';
//オプション検出
if( strpos( $key, PDBO_DEMILT ) !== false ){
//オプション取得
$tmp = $key;
$tmp = explode( PDBO_DEMILT, $tmp );
$key = $tmp[0];
$option = $tmp[1];
//テーブルにカラムが存在するか
if( !isset( $fields[$key] ) ){
throw new Exception(
"{$key}は{$this->table_name}に存在しないカラムです"
);
}
if( !is_array( $val ) ){
//文字列 日付型 の場合の処理
if( $this->isString( $fields[$key]['type'] ) ||
$this->isDate( $fields[$key]['type'] )
) {
$val = "'{$val}'";
} else {
//セカンドオプションがある時
if( isset( $tmp[2] ) ){
//セカンドオプションが文字型の時
if( $tmp[2] == 'STR' ) $val = "'{$val}'";
}
}
}
$where[] = $this->CombineStr( $key, $option, $val );
} else {
//オプションが無いとき
//テーブルにカラムが存在するか
if( !isset( $this->fields[$key] ) ){
throw new Exception(
"{$key}は{$this->table_name}に存在しないカラムです"
);
}
if( $this->isString($fields[$key]['type'] ) ) {
$where[] = "{$key} LIKE '%{$val}%'";
} else {
$where[] = "{$key} = {$val}";
}
}
}
if( count( $where ) == 0 ) return '';
return " WHERE ".implode( ' AND ', $where );
}
/**
* 配列からWhere文を生成する
*/
public function makeWhereArray( $condition ){
if( count( $condition ) == 0 ) return '';
$where = array();
foreach( $condition as $key => $val ){
if( is_string($val) && strlen( trim($val) ) == 0 ) continue;
if( is_array($val) && count( $val ) == 0 ) continue;
if( !is_array( $val ) ) $val = addslashes( $val );
$option = '';
//オプション検出
if( strpos( $key, PDBO_DEMILT ) !== false ){
//オプション取得
$tmp = $key;
$tmp = explode( PDBO_DEMILT, $tmp );
$key = $tmp[0];
$option = $tmp[1];
//セカンドオプションがある時
if( isset( $tmp[2] ) ){
//セカンドオプションが文字型の時
if( $tmp[2] == 'STR' ) $val = "'".$val."'";
}
$where[] = $this->CombineStr( $key, $option, $val );
} else {
//オプションが無いとき
$where[] = "{$key} = {$val}";
}
}
if( count( $where ) == 0 ) return '';
return " WHERE ".implode( ' AND ', $where );
}
/**
* 配列からORDER文を生成する
*/
public function makeOrderArray( $order ){
if( count( $order ) == 0 ) return '';
$ret = array();
$fields = $this->fields;
$kyes = array_keys( $order );
foreach( $order as $name => $val ){
$ret[] = "{$name} {$val}";
}
if( count( $ret ) == 0 ) return '';
return " ORDER BY ".implode( " , ", $ret );
}
/**
* フィールド生成
*/
protected function makefields( $fields ){
$ret = array();
foreach( $fields as $val ){
$val = addslashes( $val );
//オプション検出
if( strpos( $val, PDBO_DEMILT ) !== false ){
//オプション取得
$tmp = $val;
$tmp = explode( PDBO_DEMILT, $tmp );
$key = $tmp[0];
$option = $tmp[1];
$ret[] = $this->CombineField( $key, $option )."AS {$key}";
} else {
//オプションが無いとき
$ret[] = $val;
}
}
return $ret;
}
protected function CombineValue( $key, $option, $val ){
$ret = '';
switch( $option ){
//暗号 復号化
case 'decrypt':
$ret = "AES_DECRYPT('{$val}','".CRYPT_CODE."') ";
break;
//暗号 符号化
case 'crypt':
$ret = "AES_ENCRYPT('{$val}','".CRYPT_CODE."') ";
break;
//その他
default:
$ret = $val;
break;
}
return $ret;
}
/**
* セレクトのフィールド生成
*/
protected function CombineField( $key, $option ){
$ret = '';
switch( $option ){
case 'max':
$ret = "MAX( {$key} )";
break;
//暗号 復号化
case 'decrypt':
$ret = "AES_DECRYPT({$key},'".CRYPT_CODE."') ";
break;
//暗号 符号化
case 'crypt':
$ret = "AES_ENCRYPT({$key},'".CRYPT_CODE."') ";
break;
//その他
default:
$ret = $key;
break;
}
return $ret;
}
/**
* オプションに対応したSQL構築
*/
protected function CombineStr( $key, $option, $val ){
$ret = '';
switch( $option ){
case 'begin':
case 'beginYMD':
case 'from':
$ret = "{$key} >= {$val}";
break;
case 'end':
case 'endYMD':
case 'to':
$ret = "{$key} {$val}";
break;
case 'lt':
$ret = "{$key} < {$val}"; break; case '--': $ret = "{$key} {$val}"; break; case 'like': $ret = "{$key} LIKE {$val}"; break; case 'likebin': $ret = "{$key} LIKE BINARY {$val}"; break; case 'eq': $ret = "{$key} = {$val}"; break; case 'neq': $ret = "{$key} != {$val}"; break; case 'in': $ret = "{$key} IN (".implode(',', $val).")"; break; case 'not_in': $ret = "NOT ( {$key} IN (".implode(',', $val).") )"; break; case 'crypt': $ret = "AES_DECRYPT({$key},'".CRYPT_CODE."') ". " = {$val}"; break; case 'crypt_like': $ret = "AES_DECRYPT({$key},'".CRYPT_CODE."') ". "LIKE '%{$val}%'"; break; case 'crypt_likebin': $ret = "AES_DECRYPT({$key},'".CRYPT_CODE."') ". "LIKE BINARY '%{$val}%'"; break; default: throw new Exception( 'makeWhere error: '. '指定されないオプションを検出しました' ); } return $ret; } /** * ソート文構築 */ protected function makeOrder( $order ){ if( count( $order ) == 0 ) return ''; $ret = array(); $fields = $this->fields;
$kyes = array_keys( $order );
//テーブルにカラムが存在するか
foreach( $order as $name => $val ){
if( !isset( $fields[$name] ) ){
throw new Exception(
"{$name}は{$this->table_name}に存在しないカラムです"
);
}
$ret[] = "{$name} {$val}";
}
if( count( $ret ) == 0 ) return '';
return " ORDER BY ".implode( " , ", $ret );
}
/**
* 文字型かを判別する
*/
protected function isString( $type ){
switch( strtolower($type) ){
case 'char':
case 'varchar':
case 'text':
case 'longtext':
return true;
}
return false;
}
/**
* 日付型かを判別する
*/
protected function isDate( $type ){
switch( strtolower($type) ){
case 'date':
case 'datetime':
case 'timestamp':
return true;
}
return false;
}
/**
* Mysqlのカラムタイプから型とサイズ、オプション属性を切り離す
*/
private function getType( $type ){
$ret = array(
'size' => '',
'type' => '',
'option'=> '',
);
$st = 0;
$end= 0;
$st = strpos( $type, '(' );
if( $st === false ){
$ret['type'] = $type;
return $ret;
}
$ret['type'] = substr( $type, 0, $st );
$end = strpos( $type, ')' );
$ret['size'] = substr( $type, $st+1, $end-$st-1 );
$tmp = explode( ' ', $type );
if( count( $tmp ) > 1 ) $ret['option'] = $tmp[1];
return $ret;
}
/**
* プライマリーキー配列の取得
*/
private function getPrimary(){
$ret = array();
foreach( $this->fields as $name => $node ){
if( $node['key'] == 'PRI' ){
$ret[] = $name;
}
}
return $ret;
}
private function getNotNull(){
$ret = array();
foreach( $this->fields as $name => $node ){
if( $node['null'] == 'No' ){
$ret[] = $name;
}
}
return $ret;
}
/**
* $list配列内のフィールドが$fieldsに含まれているかチェックする
*/
private function existsfield( $fields, $list ){
$keys = array_keys( $fields );
foreach( $list as $name ){
if( !in_array( $name, $keys ) ) return $name;
}
return true;
}
/**
* フィールド名を取得
*/
private function getfieldName( $name ){
if( strpos( $name, PDBO_DEMILT ) === false ) return array( $name, '' );
return explode( PDBO_DEMILT, $name );
}
}
View Comments (0)