【发布时间】:2015-07-01 14:05:40
【问题描述】:
我有一个包含大约 8k 条记录的临时表(旧系统的转储,一长行包含许多详细信息),我需要将其分解,使用一些逻辑并将数据插入 3 个不同的表中。
table_temp (id, name, address, email, phone, mobile, etc......)
tbluser (id, username, password, roleid, status)
tblstudent (id, userid, name, address, classid, sectionid, etc.....)
tblstudentdetails(id, studentid, address, contact details....)
由于我需要获取数据,因此请为所有这些表添加一些逻辑并创建单独的插入语句。我试图创建大型插入语句,例如:
INSERT INTO `tbluser`(`instsessassocid`, `username`, `password`, `roleid`, `status`) VALUES
('1','PRAGUN10000@temp.com','$2y10$gFscDWwWKR8Iven6R','3','1'),
('1','SONAM10001@temp.com','$2y10$gFscDWwWKR8Iven6R','3','1'),
('1','SONAM10001@temp.com','$2y10$gFscDWwWKR8Iven6R','3','1')
其他表格也一样(你懂的):
INSERT INTO `tblstudent`(`scholarnumber`,`firstname`, `middlename`,`lastname`) VALUES
('10000','PRAGUN','','TANWAR'),('10001','SONAM','','-'),
('10002','HITESH','','KUMAR'),('10003','KHUSHI','','MEHTA'),
('10004','ADITYA','','VASYANI')
创建 4 个大型插入语句后,我将它们存储在一个数组中并将其发送到我的插入函数,该函数推迟自动提交,接受每个插入语句,一旦一切正常,提交并返回插入 ID 等。
我的应用程序似乎超时(当前设置为默认/30 秒),这么小的插入肯定不应该超时,谁能指出我做错了什么或如何改进。
这是我的插入函数:
function dbInsert($sql) {
if (is_array($sql) == 0) {
$sqlarray[] = $sql;
} else {
$sqlarray = $sql;
}
$sqlCount = count($sqlarray); //echoThis($sqlCount); die;
$con = dbConnect();
$insertID = array();
try {
// begin a transaction
$con->autocommit(FALSE);
/* commit transaction */
foreach ($sqlarray as $value) {
if ($con->query($value)) {
$insertID[] = $con->insert_id;
} else {
trigger_error(mysqli_error($con));
}
}
// if no error, commit.
if ((!mysqli_error($con)) || (!mysqli_commit($con)) && ($sqlCount === count($insertID))) {
$con->commit(); //mysqli_commit($con);
} else {
$con->rollback();
trigger_error("Error in dbInsert: " . mysqli_error_list($con));
$con->close();
}
} catch (Exception $e) {
// if any error, catch the exception and rollback
$con->rollback();
trigger_error("Error in dbInsert:" . $e);
}
/* close connection and return the result */
$con->close();
return $insertID;
}
这只是一个测试,一旦排序,我需要导入相当多的记录,所以我想要有“准备好的脚本”,我可以根据需要使用它们。
我知道加载 infile 或 mysqlimport 方式,但我需要逻辑,我真的认为我的脚本应该能够完成这项工作。请注意,我在我的本地主机上,合理的配置机器没有其他任何事情发生。
谢谢!
【问题讨论】:
-
您使用的是 MyIsam 表还是 Innodb? Innodb 支持事务,但导入速度相当慢。如果要计算执行时间,可以尝试导入少量行并获取操作前后的时间戳。完成后,计算脚本需要多长时间是一件小事
-
@Osuwariboy,我正在使用 innodb。是的,我可以把它分解成更小的脚本。但是,大约 3k 条记录(这是一组插入的记录)应该超时吗?我正在做的事情有什么严重的错误,或者它就是这样吗?谢谢大家!