gnh1201/reasonableframework
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update database.alt.php

Browse Source
This commit is contained in:
Namhyeon Go 2018-09-12 11:26:11 +09:00 committed by GitHub
parent 294498a56e
commit 971d17d892
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 23 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
helper/database.alt.php
View File

@ -6,6 +6,23 @@
* @brief Database alternative driver switcher * @brief Database alternative driver switcher
*/ */
if(!function_exists("exec_db_alt_callback")) {
function exec_db_alt_callback($rules) {
$result = false;
foreach($rules as $rule) {
if($rule['driver'] == $driver) {
if(loadHelper(sprintf("database.%s", $rule['driver']))) {
$result = function_exists($rule['callback']) ? call_user_func($rule['callback']) : $result;
}
break;
}
}
return $result;
}
}
if(!function_exists("get_db_alt_connect")) { if(!function_exists("get_db_alt_connect")) {
function get_db_alt_connect($driver) { function get_db_alt_connect($driver) {
$conn = false; $conn = false;
@ -29,15 +46,8 @@ if(!function_exists("get_db_alt_connect")) {
"callback" => "get_db_oracle_connect" "callback" => "get_db_oracle_connect"
) )
); );
foreach($rules as $rule) { $conn = exec_db_alt_callback($rules);
if($rule['driver'] == $driver) {
if(loadHelper(sprintf("database.%s", $rule['driver']))) {
$conn = function_exists($rule['callback']) ? call_user_func($rule['callback']) : $conn;
}
break;
}
}
return $conn; return $conn;
} }
@ -65,15 +75,8 @@ if(!function_exists("exec_db_alt_query")) {
"callback" => "exec_db_oracle_query" "callback" => "exec_db_oracle_query"
) )
); );
foreach($rules as $rule) { $result = exec_db_alt_callback($rules);
if($rule['driver'] == $driver) {
if(loadHelper(sprintf("database.%s", $rule['driver']))) {
$result = function_exists($rule['callback']) ? call_user_func($rule['callback']) : $result;
}
break;
}
}
return $result; return $result;
} }
@ -101,15 +104,8 @@ if(!function_exists("exec_db_alt_fetch_all")) {
"callback" => "exec_db_oracle_fetch_all" "callback" => "exec_db_oracle_fetch_all"
) )
); );
foreach($rules as $rule) { $rows = exec_db_alt_callback($rules);
if($rule['driver'] == $driver) {
if(loadHelper(sprintf("database.%s", $rule['driver']))) {
$rows = function_exists($rule['callback']) ? call_user_func($rule['callback']) : $rows;
}
break;
}
}
return $rows; return $rows;
} }