sel_name = $sel_name
";
/*
LOAD DATA [LOW_PRIORITY] [LOCAL] INFILE 'file_name.txt' [REPLACE | IGNORE]
INTO TABLE tbl_name
[FIELDS
[TERMINATED BY '\t']
[OPTIONALLY] ENCLOSED BY '']
[ESCAPED BY '\\' ]]
[LINES TERMINATED BY '\n']
[IGNORE number LINES]
[(col_name,...)]
例:
LOAD DATA LOCAL INFILE '/tmp/phpBGhA33'
INTO TABLE OMC_Def_test
FIELDS
TERMINATED BY ','
ENCLOSED BY '\"'
ESCAPED BY '\\'(可省略)
LINES
TERMINATED BY '\n'
IGNORE 1 LINES
*/
$remark_style=array(
'sign' =>'#',
'fields_by' =>',',
'lines_by' =>'\n',
'fields_seek' =>'1'
);
$data_style=array(
'fields_by' =>',',
'enclosed_by'=>'\"',
'escaped_by' =>'\\',
'lines_by' =>'\n',
'ignore_lines' =>'0',
'mode' =>'REPLACE'
);
echo "test
";
//get load out information
$info_sql = "SELECT * FROM $syscsvconf_table WHERE key_menu_id='$key_menu_id'";
if($DEBUG) echo "
info_sql = $info_sql";//调试用
$result = mysqli_query($pubConn,$info_sql);
$info_rows = mysqli_fetch_array($result);
$server_name = $info_rows[server_name];
$db_name = $info_rows[db_name];
$table_name = $info_rows[table_name];
$where_find = $info_rows[where_find];
$sys_id = $info_rows[sys_id];
$obj_id = $info_rows[obj_id];
$if_enable = $info_rows[if_enable];
$if_enable =0;
$if_subsys = $info_rows[if_subsys];
$menu_name = $info_rows[menu_name];
$menu_name_2 = $info_rows[menu_name_2];
$log_name = "Upload--"."'$server_name' '$db_name' '$table_name'";
/*
$sel_field_list= mysql_list_fields($db_name,$table_name);
$sel_field_num = mysql_num_fields($sel_field_list);
if($DEBUG) echo "
sel_field_num=$sel_field_num";
for($i=0;$i<$sel_field_num;$i++){
$sel_field_name = mysql_field_name($sel_field_list, $i);
if($sel_field_name=='mflag'){
$if_enable=1;
break;
}
}
*/
if($DEBUG) echo "
if_enable=$if_enable";
if($DEBUG) echo "
if_subsys=$if_subsys";
if($if_subsys>0){
$subsys_num = omc_sys_id_info($sys_id,subsys_num);
echo "
subsys_num=$subsys_num";
}
$load_file_info=array(
'name' =>$textfile,
'server'=>$server_name,
'db' =>$db_name,
'table' =>$table_name
);
if(isset($textfile) && $textfile != "none"){
if($DEBUG) echo "
LOAD DATA file -> $textfile
";
if (($table_name == 'paramConf') ||($table_name == 'subsParamConf_0')||($table_name == 'subsParamConf_1')||($table_name == 'logAttrDef_0')||($table_name == 'logAttrDef_1')){
$del_sql = "DELETE FROM $table_name";
if($DEBUG) echo "
del_sql = $del_sql";
$del_result = mysqli_query($pubConn,$del_sql);
if($DEBUG) echo "
del_result=$del_result";
$insert_sql = "LOAD DATA LOCAL INFILE '$textfile'
INTO TABLE $table_name
FIELDS TERMINATED BY ','
LINES TERMINATED BY '\n'
";
if($DEBUG) echo "
insert_sql=$insert_sql";
$insert_result=mysqli_query($pubConn,$insert_sql);
$log_name="UPLOAD $db_name-$table_name";
if($DEBUG) echo "
insert_result=$insert_result";
if ($insert_result){
$log_name=$log_name." successful.";
$update_sql="UPDATE $syscsvconf_table SET last_upload = CURRENT_TIMESTAMP WHERE key_menu_id='$key_menu_id'";
mysqli_query($pubConn,$update_sql);
}
else
$log_name=$log_name." fail.";
insertLog("$log_name");
}
//elseif (omc_chk_load_in($load_file_info,$remark_style) > 0){
else{
//empty existed table
if($DEBUG) $drop_sql="DROP TABLE IF EXISTS load_temp";
$drop_result=mysqli_query($pubConn,$drop_sql);
$create_sql="CREATE TABLE IF NOT EXISTS load_temp SELECT * FROM $table_name LIMIT 0,0";
if($DEBUG) echo "
create_sql=$create_sql";
$create_result=mysqli_query($pubConn,$create_sql);
//如果建表成功,把文件数据导入临时表
if($create_result>0){
$load_sql="LOAD DATA LOCAL INFILE '$textfile' $data_style[mode]
INTO TABLE load_temp
FIELDS
TERMINATED BY '$data_style[fields_by]'
ENCLOSED BY '$data_style[enclosed_by]'
LINES
TERMINATED BY '$data_style[lines_by]'
IGNORE $data_style[ignore_lines] LINES
";
if($DEBUG) echo "
load_sql=$load_sql";
if(0)
{
$link = mysqli_init();
mysqli_options($link, MYSQLI_OPT_LOCAL_INFILE, true);
mysqli_real_connect($link, 'localhost', root, rootaa, PPS_DB);
$load_result=mysqli_query($load_sql);
}
if(1)
{
$hostname="localhost";
$username="root";
$password="rootaa";
$db = mysql_connect($hostname, $username, $password, false, 128); // 128 enables LOCAL INFILE
mysql_select_db($db_name, $db);
$load_result = mysql_query($load_sql,$db) or
die("Invalid query: $load_sql\n" . mysqli_error($pubConn));
}
else
{
$load_result=mysqli_query($pubConn,$load_sql);
}
//$load_result=mysqli_query($pubConn,$load_sql);
if($DEBUG) echo "load_resul[$load_result]
";
if(0)
{
echo mysqli_error($pubConn);
echo "load_sql[$load_sql] load_resul[$load_result]
";
exit();
}
//如果导入成功,把临时表作相应改变
if($load_result > 0){
//删除空记录
$sel_field_list= mysql_list_fields($db_name,$table_name);
$sel_field_num = mysql_num_fields($sel_field_list);
$sel_all_field='';
for($i=0;$i<$sel_field_num;$i++){
$sel_field_name = mysql_field_name($sel_field_list, $i);
if($i==$sel_field_num-1)
{
$sel_all_field.=$sel_field_name."=''";
}
else
{
$sel_all_field.=$sel_field_name."='' AND ";
}
}
$del_sql = " DELETE FROM load_temp WHERE ".$sel_all_field;
if ($DEBUG) echo "
del_sql=$del_sql";
$del_result = mysqli_query($pubConn,$del_sql);
//如果是参数表
if($if_subsys > 0){
$update_sql="UPDATE load_temp SET key_subsys_id=$subsys_num";
}elseif($if_enable > 0){
$sel_field_list= mysql_list_fields($db_name,$table_name);
$sel_field_num = mysql_num_fields($sel_field_list);
if($DEBUG) echo "
sel_field_num=$sel_field_num";
$set_all_field='';
for($i=0;$i<$sel_field_num;$i++){
$sel_field_name = mysql_field_name($sel_field_list, $i);
if(substr($sel_field_name,0,1)=='E'){
$set_field=substr($sel_field_name,2);
$set_all_field=$set_all_field.",".$sel_field_name."=".$set_field;
}
}
$set_total_field="mflag='1'".$set_all_field;
$update_sql="UPDATE load_temp SET ".$set_total_field;
if($DEBUG) echo "
update_sql=$update_sql";
}
if($if_subsys > 0 || $if_enable > 0){
$update_result=mysqli_query($pubConn,$update_sql);
}else{
$update_result=1;
}
if(0) echo "update_result[$update_result]
";
//echo "
update_sql=$update_sql";
//如果修改成功,把临时表数据一条条插入相应表
if($update_result > 0){
$select_sql="SELECT * FROM load_temp";
$select_result=mysqli_query($pubConn,$select_sql);
$sel_field_num = mysql_num_fields($select_result);
$select_rows=mysqli_fetch_array($select_result);
do{
$sel_val='';
for($i=0;$i<$sel_field_num;$i++){
$select_rows[$i]=str_replace("'","\'",$select_rows[$i]);
if($i==$sel_field_num-1){
if($i==0){
$sel_val="'".$select_rows[$i]."'";
}else{
$sel_val=$sel_val."'".$select_rows[$i]."'";
}
}else{
if($i==0){
$sel_val="'".$select_rows[$i]."'".",";
}else{
$sel_val=$sel_val."'".$select_rows[$i]."'".",";
}
}
//echo "
sel_val=$sel_val";
}
$replace_sql="REPLACE $table_name VALUES($sel_val)";
if ($DEBUG) echo "
replace_sql=$replace_sql";
$replace_result=mysqli_query($pubConn,$replace_sql);
}while($select_rows=mysqli_fetch_array($select_result));
if($table_name=='pre_mo_tariff'||$table_name=='pre_mt_tariff'){
$tmpSql=" SELECT bill_id,tariff_id FROM $table_name";
if($DEBUG)echo "
tmpSql=$tmpSql";
$tmpRes = @mysqli_query($pubConn,$tmpSql);
$tmpRow = @mysqli_fetch_array($tmpRes);
echo mysqli_error($pubConn);
do
{
$tmp_bill_id = $tmpRow[bill_id];
$tmp_tariff_id = $tmpRow[tariff_id];
for($count=0;$count'9'){
if($tmp_bill_id[$count]!='B'&&$tmp_bill_id[$count]!='b'&&$tmp_bill_id[$count]!='C'&&$tmp_bill_id[$count]!='c'){
$failFlag='1';
$delSql=" DELETE FROM $table_name WHERE tariff_id='$tmp_tariff_id' AND bill_id='$tmp_bill_id'";
//echo "
$delSql";
$delRes = @mysqli_query($pubConn,$delSql);
echo mysqli_error($pubConn);
echo "";
break;
}
}
}
}while($tmpRow = @mysqli_fetch_array($tmpRes));
if($failFlag=='1'){
echo "";
}
}
//如果导入成功,给出成功上载标志
if($replace_result>0){
echo "
$strOperateDatabaseSuccess";
$input_success=1;
//如果需要通知底层
if($if_enable>0){
$command_type='1';
$send_result=send_shm_module($obj_id,$command_type);//设置共享内存
if($send_result<0){
$update_sql = "UPDATE $table_name set mflag = '0'";
//echo "
update_sql=$update_sql";
$result=mysqli_query($pubConn,$update_sql);
}//end if($send_result<0)
}//end ifif($if_enable>0)
}//end if($replace_result>0)
else{
echo "replace err
";
echo mysqli_error($pubConn);
}
}//end if($update_result>0)
}//end if($load_result>0)
}//end if($create_result>0)
if($input_success==0){
echo "
$strOperateDatabaseFailure";
echo mysqli_error($pubConn);
exit();
}
$drop_sql="DROP TABLE IF EXISTS load_temp";
$drop_result=mysqli_query($pubConn,$drop_sql);
if($input_success>0){
//edit log_name
$log_name=$log_name." successful.";
//update last download time
$update_sql="UPDATE $syscsvconf_table SET last_upload = CURRENT_TIMESTAMP WHERE key_menu_id='$key_menu_id'";
mysqli_query($pubConn,$update_sql);
}else{
$log_name=$log_name." fail.";
echo "
$strOperateDatabaseFailure";
echo mysqli_error($pubConn);
}
insertLog("$log_name");
//@unlink($textfile);
//}else{
// echo "$strDataUploadError";
// $log_name=$log_name." $strDataUploadError.";
// insertLog("$log_name");
}
}elseif(isset($textfile)){
echo "
Upload csv file failed, File isn't exist or file is empty!";
}
?>
";
/*
if($load_sys_type==0){//如果是TS_OMC
echo "
$strNoteUploadParameter
";
}
*/
if ($insert_result == 1){
echo "
$strUploadSucc
";
}
elseif ($insert_result == 0){
echo "
$strUploadUnSucc
";
}
?>