PHP读取TXT文件写入数据库
2013-07-22 09:45
579 查看
PHP读取TXT文件写入数据库完整代码如下(包括文件类型、大小、字段为空的判断,以及事务的处理):
<?php
$uploadfile="../upload_files/".basename($_FILES['userfile']['name']);
$message="";
//判断上传文件格式
$string="txt";
$extend = pathinfo($_FILES['userfile']['name']);
$extend = strtolower($extend["extension"]);
if ($extend!=$string){
$message='上传文件不是TXT类型!';
print "{success:false,msg:'".$message."'}";
}else {
// //判断文件大小
// if($_FILES['userfile']['size']>1024*1000){
// return null;
// }
if(@move_uploaded_file($_FILES['userfile']['tmp_name'],$uploadfile)){
//文件上传服务器成功,将文件导入数据库中
$fp=fopen($uploadfile, 'r');//以只读方式打开文件
$content=fread($fp, filesize($uploadfile));//读文件
fclose($fp);
//通过一个正则表达式分隔字符串
$content=preg_split('/\r\n/',$content,-1,PREG_SPLIT_NO_EMPTY);//记录间用换行符分隔
//连接数据库
include_once '../libraries/db.php';
$db=new Db();
$conn = $db->mssqlConnetion();
if($conn === false )
{
die( print_r( sqlsrv_errors(), true));
return NULL;
}else{
//连接成功,将记录循环插入到数据库表中
//启动事务
if(sqlsrv_begin_transaction($conn)===false){
die(print_r(sqlsrv_errors(),true));
}
if (perform_trans_ops($conn,$content)){
if (sqlsrv_commit($conn)){
$message='文件上传成功!';
print "{success:true,msg:'".$message."'}";
}else{
$message='文件上传失败!';
print "{success:false,msg:'".$message."'}";
sqlsrv_rollback($conn);//事务检查异常,回滚事务
}
}else{
sqlsrv_rollback($conn);//事务检查异常,回滚事务
}
}
sqlsrv_close($conn);
}else{
$message='文件上传受阻!';
print "{success:false,msg:'".$message."'}";
}
}
function perform_trans_ops($conn,$content){
$params = array();
$options = array( "Scrollable" => SQLSRV_CURSOR_KEYSET );
foreach ($content as $k=>$v){
$str=explode(',,', $v);//字段间用符号分隔
//去除字符串首尾空格
$str[0]=trim($str[0]);
$str[1]=trim($str[1]);
$str[11]=trim($str[11]);
$str[12]=trim($str[12]);
//判断非空字段是否为空
if(empty($str[0])||empty($str[1])||empty($str[11])||empty($str[12])){
$message='编号、标题、行业、类目不能为空,文件上传失败!';
print "{success:false,msg:'".$message."'}";
return false;
}
//数据库操作
$sql = "INSERT INTO bio_Information(Info_ID,Info_Title,Info_Author,Info_Origin,Info_Theme,Info_Keyword,Info_PubTime,Info_Abstract,Info_Format,Info_IsFull,Info_IsDown,Info_Trade,Info_Category,Info_Path,Info_Remark,Info_Content,Info_ContentBlock)
VALUES('".(int)$str[0]."','".$str[1]."','".$str[2]."','".$str[3]."','".$str[4]."','".$str[5]."','".$str[6]."','".$str[7]."','".$str[8]."','".$str[9]."','".$str[10]."','".$str[11]."','".$str[12]."','".$str[13]."','".$str[14]."','".$str[15]."','".$str[16]."')";
$Stmt = sqlsrv_query( $conn, $sql , $params, $options );
if ($Stmt===false)
{
die( print_r( sqlsrv_errors(), true) );
$message='文件数据上传失败!';
print "{success:false,msg:'".$message."'}";
return false;
}
}
return true;
sqlsrv_free_stmt($Stmt);
}
<?php
$uploadfile="../upload_files/".basename($_FILES['userfile']['name']);
$message="";
//判断上传文件格式
$string="txt";
$extend = pathinfo($_FILES['userfile']['name']);
$extend = strtolower($extend["extension"]);
if ($extend!=$string){
$message='上传文件不是TXT类型!';
print "{success:false,msg:'".$message."'}";
}else {
// //判断文件大小
// if($_FILES['userfile']['size']>1024*1000){
// return null;
// }
if(@move_uploaded_file($_FILES['userfile']['tmp_name'],$uploadfile)){
//文件上传服务器成功,将文件导入数据库中
$fp=fopen($uploadfile, 'r');//以只读方式打开文件
$content=fread($fp, filesize($uploadfile));//读文件
fclose($fp);
//通过一个正则表达式分隔字符串
$content=preg_split('/\r\n/',$content,-1,PREG_SPLIT_NO_EMPTY);//记录间用换行符分隔
//连接数据库
include_once '../libraries/db.php';
$db=new Db();
$conn = $db->mssqlConnetion();
if($conn === false )
{
die( print_r( sqlsrv_errors(), true));
return NULL;
}else{
//连接成功,将记录循环插入到数据库表中
//启动事务
if(sqlsrv_begin_transaction($conn)===false){
die(print_r(sqlsrv_errors(),true));
}
if (perform_trans_ops($conn,$content)){
if (sqlsrv_commit($conn)){
$message='文件上传成功!';
print "{success:true,msg:'".$message."'}";
}else{
$message='文件上传失败!';
print "{success:false,msg:'".$message."'}";
sqlsrv_rollback($conn);//事务检查异常,回滚事务
}
}else{
sqlsrv_rollback($conn);//事务检查异常,回滚事务
}
}
sqlsrv_close($conn);
}else{
$message='文件上传受阻!';
print "{success:false,msg:'".$message."'}";
}
}
function perform_trans_ops($conn,$content){
$params = array();
$options = array( "Scrollable" => SQLSRV_CURSOR_KEYSET );
foreach ($content as $k=>$v){
$str=explode(',,', $v);//字段间用符号分隔
//去除字符串首尾空格
$str[0]=trim($str[0]);
$str[1]=trim($str[1]);
$str[11]=trim($str[11]);
$str[12]=trim($str[12]);
//判断非空字段是否为空
if(empty($str[0])||empty($str[1])||empty($str[11])||empty($str[12])){
$message='编号、标题、行业、类目不能为空,文件上传失败!';
print "{success:false,msg:'".$message."'}";
return false;
}
//数据库操作
$sql = "INSERT INTO bio_Information(Info_ID,Info_Title,Info_Author,Info_Origin,Info_Theme,Info_Keyword,Info_PubTime,Info_Abstract,Info_Format,Info_IsFull,Info_IsDown,Info_Trade,Info_Category,Info_Path,Info_Remark,Info_Content,Info_ContentBlock)
VALUES('".(int)$str[0]."','".$str[1]."','".$str[2]."','".$str[3]."','".$str[4]."','".$str[5]."','".$str[6]."','".$str[7]."','".$str[8]."','".$str[9]."','".$str[10]."','".$str[11]."','".$str[12]."','".$str[13]."','".$str[14]."','".$str[15]."','".$str[16]."')";
$Stmt = sqlsrv_query( $conn, $sql , $params, $options );
if ($Stmt===false)
{
die( print_r( sqlsrv_errors(), true) );
$message='文件数据上传失败!';
print "{success:false,msg:'".$message."'}";
return false;
}
}
return true;
sqlsrv_free_stmt($Stmt);
}
相关文章推荐
- PHP读取TXT文件写入数据库
- PHP读取TXT文件写入数据库
- PHP读取TXT文件写入数据库
- PHP 从数据库读取写入txt文件
- PHP读取TXT文件写入数据库
- PHP读取TXT文件写入数据库
- PHP读取TXT文件写入数据库
- PHP读取TXT文件写入数据库
- PHP读取TXT文件写入数据库
- PHP读取TXT文件写入数据库
- PHP读取TXT文件写入数据库
- PHP读取TXT文件写入数据库
- PHP读取TXT文件写入数据库
- PHP读取TXT文件写入数据库
- PHP读取TXT文件写入数据库
- PHP读取TXT文件写入数据库
- PHP读取TXT文件写入数据库
- PHP读取TXT文件写入数据库
- 基于PHP读取TXT文件向数据库导入海量数据的方法
- Spring Batch读取txt文件并写入数据库的方法教程