Update database.php
This commit is contained in:
parent
9b27de8c45
commit
5ec1a640e8
|
@ -685,6 +685,7 @@ if(!check_function_exists("sql_query")) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
// get timediff
|
// get timediff
|
||||||
if(!check_function_exists("get_timediff_on_query")) {
|
if(!check_function_exists("get_timediff_on_query")) {
|
||||||
function get_timediff_on_query($a, $b) {
|
function get_timediff_on_query($a, $b) {
|
||||||
|
@ -702,25 +703,57 @@ if(!check_function_exists("get_timediff_on_query")) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// temporary table
|
// table creation
|
||||||
if(!check_function_exists("exec_db_temp_create")) {
|
if(!check_function_exists("get_bind_to_sql_create")) {
|
||||||
function exec_db_temp_create($schemes=array(), $options=array()) {
|
function get_bind_to_sql_create($schemes, $options=array()) {
|
||||||
$_tablename = make_random_id();
|
$sql = false;
|
||||||
|
|
||||||
|
$_prefix = get_value_in_array("prefix", $options, "");
|
||||||
|
$_suffix = get_value_in_array("suffix", $options, "");
|
||||||
|
$_tablename = get_value_in_array("tablename", $options, "");
|
||||||
$_schemes = array();
|
$_schemes = array();
|
||||||
foreach($schemes as $k=>$v) {
|
|
||||||
if(is_array($v)) {
|
$setindex = get_value_in_array("setindex", $options, false);
|
||||||
$_argc = count($v);
|
$temporary = get_value_in_array("temporary", $options, false);
|
||||||
if($_argc == 1) {
|
|
||||||
$_schemes[] = sprintf("%s %s", $k, $v[0]);
|
if(!empty($_tablename)) {
|
||||||
} elseif($_argc == 2) {
|
$tablename = sprintf("%s%s%s", $_prefix, $_tablename, $_suffix);
|
||||||
$_schemes[] = sprintf("%s %s(%s)", $k, $v[0], $v[1]);
|
|
||||||
} elseif($_argc == 3) {
|
foreach($schemes as $k=>$v) {
|
||||||
$_schemes[] = sprintf("%s %s(%s) %s", $k, $v[0], $v[1], ($v[2] === true ? "not null" : ""));
|
if(is_array($v)) {
|
||||||
|
$_argc = count($v);
|
||||||
|
if($_argc == 1) {
|
||||||
|
$_schemes[] = sprintf("%s %s", $k, $v[0]);
|
||||||
|
} elseif($_argc == 2) {
|
||||||
|
$_schemes[] = sprintf("%s %s(%s)", $k, $v[0], $v[1]);
|
||||||
|
} elseif($_argc == 3) {
|
||||||
|
$_schemes[] = sprintf("%s %s(%s) %s", $k, $v[0], $v[1], ($v[2] === true ? "not null" : ""));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if($temporary !== false) {
|
||||||
|
$sql = sprintf("create temporary table if not exists %s (%s)", $tablename, implode(",", $_schemes));
|
||||||
|
} else {
|
||||||
|
$sql = sprintf("create table if not exists %s (%s)", $tablename, implode(",", $_schemes));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
$_sql = sprintf("create temporary table if not exists %s (%s)", $_tablename, implode(",", $_schemes));
|
|
||||||
return (exec_db_query($_sql) ? $_tablename : false);
|
return $sql;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// temporary table creation
|
||||||
|
if(!check_function_exists("exec_db_temp_create")) {
|
||||||
|
function exec_db_temp_create($schemes, $options=array()) {
|
||||||
|
$tablename = make_random_id();
|
||||||
|
|
||||||
|
$sql = get_bind_to_sql_create($schemes, array(
|
||||||
|
"tablename" => $tablename,
|
||||||
|
"temporary" => true
|
||||||
|
));
|
||||||
|
|
||||||
|
return (exec_db_query($sql) ? $tablename : false);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue
Block a user