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;
break;
case "thin":
echo "doing filename: $filename dbname: $dbname table:$table
";
$sDescDbFile = _DIR_DICT_SYSTEM_."/".$dbname;
$csvfile = _DIR_DICT_TEXT_."/thin/{$filename}";
$dns = "sqlite:".$sDescDbFile;
$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 dict ('id','language', 'dict_id', 'eword', 'word', 'paliword', 'mean', 'length', 'status') VALUES ( ? , ? , ? , ? , ? , ? , ? , ? , ? )";
}
else if($table==="info"){
$query="INSERT INTO info ('language' , 'id' , 'shortname' , 'name') VALUES ( ? , ? , ? , ? )";
}
else{
echo "table name $table unkow.";
}
}
else if($dbname==="ref1.db"){
$query="INSERT INTO dict ('id','eword', 'word', 'length', 'count') VALUES ( ? , ? , ? , ? , ? )";
}
else{
echo "db name $dbname unkow.";
}
$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;
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){
$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;
}
?>