true));
$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
if(strstr($filename,".",true)===strstr($dbname,".",true)){
//建立数据库
$_sql = file_get_contents('rich_dict.sql');
$_arr = explode(';', $_sql);
//执行sql语句
foreach ($_arr as $_value) {
$dbh->query($_value.';');
}
echo $dns."建立数据库成功
";
}
// 开始一个事务，关闭自动提交
$dbh->beginTransaction();
$query="INSERT INTO dict ('id','pali', 'type', 'gramma', 'parent', 'mean', 'note', 'parts', 'partmean', 'status', 'confidence', 'len', 'dict_name', 'lang') VALUES ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
$stmt = $dbh->prepare($query);
$count=0;
// 打开文件并读取数据
if(($fp=fopen($csvfile, "r"))!==FALSE){
while(($data=fgetcsv($fp,0,','))!==FALSE){
//id,wid,book,paragraph,word,real,type,gramma,mean,note,part,partmean,bmc,bmt,un,style,vri,sya,si,ka,pi,pa,kam
$stmt->execute($data);
$count++;
}
fclose($fp);
echo "单词表load
";
}
else{
echo "can not open csv file. ";
}
// 提交更改
$dbh->commit();
if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
$error = $dbh->errorInfo();
echo "error - $error[2]
";
}
else{
echo "updata $count recorders.";
}
$dbh = null;
if(copy($dbfilename,$sDescDbFile)){
echo "文件复制成功
";
}
else{
echo "文件复制失败
";
}
break;
case "thin":
$dbfilename = _DIR_DICT_TEXT_."/system/{$dbname}";
$sDescDbFile = _DIR_DICT_SYSTEM_."/".$dbname;
$csvfile = _DIR_DICT_TEXT_."/system/{$filename}";
$dns = "sqlite:".$dbfilename;
$dbh = new PDO($dns, "", "",array(PDO::ATTR_PERSISTENT=>true));
$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
// 开始一个事务，关闭自动提交
$dbh->beginTransaction();
if($dbname==="ref.db"){
if($table==="dict"){
$query="INSERT INTO {$table} ('id','pali', 'type', 'gramma', 'parent', 'mean', 'note', 'parts', 'partmean', 'status', 'confidence', 'len', 'dict_name', 'lang') VALUES ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
}
else if($table==="info"){
$query="INSERT INTO {$table} ('id','pali', 'type', 'gramma', 'parent', 'mean', 'note', 'parts', 'partmean', 'status', 'confidence', 'len', 'dict_name', 'lang') VALUES ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
}
}
else if($dbname==="ref1.db"){
$query="INSERT INTO {$table} ('id','pali', 'type', 'gramma', 'parent', 'mean', 'note', 'parts', 'partmean', 'status', 'confidence', 'len', 'dict_name', 'lang') VALUES ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
}
$stmt = $dbh->prepare($query);
$count=0;
// 打开文件并读取数据
if(($fp=fopen($csvfile, "r"))!==FALSE){
while(($data=fgetcsv($fp,0,','))!==FALSE){
$stmt->execute($data);
$count++;
}
fclose($fp);
echo "单词表load
";
}
else{
echo "can not open csv file. ";
}
// 提交更改
$dbh->commit();
if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
$error = $dbh->errorInfo();
echo "error - $error[2]
";
}
else{
echo "updata $count recorders.";
}
$dbh = null;
if(copy($dbfilename,$sDescDbFile)){
echo "文件复制成功
";
}
else{
echo "文件复制失败
";
}
break;
case "part":
$dns = "sqlite:"._FILE_DB_part_;
$dbh = new PDO($dns, "", "",array(PDO::ATTR_PERSISTENT=>true));
$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
{
//建立数据库
$_sql = file_get_contents('part.sql');
$_arr = explode(';', $_sql);
//执行sql语句
foreach ($_arr as $_value) {
$dbh->query($_value.';');
}
echo $dns."建立数据库成功
";
}
// 开始一个事务，关闭自动提交
$dbh->beginTransaction();
$query="INSERT INTO part ('word','weight') VALUES ( ?, ? )";
$stmt = $dbh->prepare($query);
$count=0;
// 打开文件并读取数据
if(($fp=fopen(_DIR_DICT_TEXT_."/system/part.csv", "r"))!==FALSE){
while(($data=fgetcsv($fp,0,','))!==FALSE){
//id,wid,book,paragraph,word,real,type,gramma,mean,note,part,partmean,bmc,bmt,un,style,vri,sya,si,ka,pi,pa,kam
$stmt->execute($data);
$count++;
}
fclose($fp);
echo "part load ";
}
else{
echo "can not open csv file. ";
}
// 提交更改
$dbh->commit();
if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
$error = $dbh->errorInfo();
echo "error - $error[2]
";
}
else{
echo "updata $count recorders.";
}
$dbh = null;
break;
}
?>