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

Update database.php

Browse Source
This commit is contained in:
Namhyeon Go 2020-02-17 20:55:59 +09:00 committed by GitHub
parent 9233c87f1f
commit f54750dfea
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
system/database.php
View File

@ -363,20 +363,22 @@ if(!is_fn("exec_db_bulk_start")) {
function exec_db_bulk_start() {
$bulkid = make_random_id();
set_shared_var("bulk_" . $bulkid, array());
write_common_log("bulk started: " . $bulkid);
return $bulkid;
}
}
if(!is_fn("exec_db_bulk_push")) {
function exec_db_bulk_push($bind, $bulkid) {
function exec_db_bulk_push($bulkid, $bind) {
$rows = get_shared_var("bulk_" . $bulkid);
$rows[] = $bind;
set_shared_var("bulk_" . $bulkid, $rows);
//write_common_log("bulk pushed: " . $bulkid . " / " . count($rows));
}
}
if(!is_fn("exec_db_bulk_end")) {
function exec_db_bulk_end($bulkid, $bindkeys) {
function exec_db_bulk_end($bulkid, $tablename, $bindkeys) {
$rows = get_shared_var("bulk_" . $bulkid);
$sql = "insert into `%s` (%s) values (%s)";
@ -385,12 +387,14 @@ if(!is_fn("exec_db_bulk_end")) {
$s3a = array();
foreach($rows as $row) {
$s3a[] = sprintf("`%s`", implode("`, `", $row));
$s3a[] = sprintf("'%s'", implode("', '", $row));
}
$s3 = implode("), (", $s3a);
$sql = sprintf($sql, $s1, $s2, $s3);
//write_common_log("bulk ended: " . $sql);
return exec_db_query($sql);
}
}