<?php
function
loadTxtDataIntoDatabase(
$splitChar
,
$file
,
$table
,
$conn
,
$fields
=
array
(),
$insertType
=
'INSERT'
){
if
(
empty
(
$fields
))
$head
=
"{$insertType} INTO `{$table}` VALUES('"
;
else
$head
=
"{$insertType} INTO `{$table}`(`"
.implode(
'`,`'
,
$fields
).
"`) VALUES('"
;
$end
=
"')"
;
$sqldata
= trim(
file_get_contents
(
$file
));
if
(preg_replace(
'/\s*/i'
,
''
,
$splitChar
) ==
''
) {
$splitChar
=
'/(\w+)(\s+)/i'
;
$replace
=
"$1','"
;
$specialFunc
=
'preg_replace'
;
}
else
{
$splitChar
=
$splitChar
;
$replace
=
"','"
;
$specialFunc
=
'str_replace'
;
}
$sqldata
= preg_replace(
'/(\s*)(\n+)(\s*)/i'
,
'\'),(\''
,
$sqldata
);
$sqldata
=
$specialFunc
(
$splitChar
,
$replace
,
$sqldata
);
$query
=
$head
.
$sqldata
.
$end
;
if
(mysql_query(
$query
,
$conn
))
return
array
(true);
else
{
return
array
(false,mysql_error(
$conn
),mysql_errno(
$conn
));
}
}
require
'db.php'
;
$splitChar
=
'|'
;
$file
=
'sqldata1.txt'
;
$fields
=
array
(
'id'
,
'parentid'
,
'name'
);
$table
=
'cengji'
;
$result
= loadTxtDataIntoDatabase(
$splitChar
,
$file
,
$table
,
$conn
,
$fields
);
if
(
array_shift
(
$result
)){
echo
'Success!<br/>'
;
}
else
{
echo
'Failed!--Error:'
.
array_shift
(
$result
).
'<br/>'
;
}
require
'db.php'
;
$splitChar
=
' '
;
$file
=
'sqldata2.txt'
;
$fields
=
array
(
'id'
,
'make'
,
'model'
,
'year'
);
$table
=
'cars'
;
$result
= loadTxtDataIntoDatabase(
$splitChar
,
$file
,
$table
,
$conn
,
$fields
);
if
(
array_shift
(
$result
)){
echo
'Success!<br/>'
;
}
else
{
echo
'Failed!--Error:'
.
array_shift
(
$result
).
'<br/>'
;
}
require
'db.php'
;
$splitChar
=
' '
;
$file
=
'sqldata3.txt'
;
$fields
=
array
(
'id'
,
'make'
,
'model'
,
'year'
);
$table
=
'cars'
;
$insertType
=
'REPLACE'
;
$result
= loadTxtDataIntoDatabase(
$splitChar
,
$file
,
$table
,
$conn
,
$fields
,
$insertType
);
if
(
array_shift
(
$result
)){
echo
'Success!<br/>'
;
}
else
{
echo
'Failed!--Error:'
.
array_shift
(
$result
).
'<br/>'
;
}
require
'db.php'
;
$splitChar
=
' '
;
$file
=
'sqldata3.txt'
;
$fields
=
array
(
'id'
,
'value'
);
$table
=
'notExist'
;
$result
= loadTxtDataIntoDatabase(
$splitChar
,
$file
,
$table
,
$conn
,
$fields
);
if
(
array_shift
(
$result
)){
echo
'Success!<br/>'
;
}
else
{
echo
'Failed!--Error:'
.
array_shift
(
$result
).
'<br/>'
;
}
/*
?>
<?php
static
$connect
= null;
static
$table
=
'jilian'
;
if
(!isset(
$connect
)) {
$connect
= mysql_connect(
"localhost"
,
"root"
,
""
);
if
(!
$connect
) {
$connect
= mysql_connect(
"localhost"
,
"Zjmainstay"
,
""
);
}
if
(!
$connect
) {
die
(
'Can not connect to database.Fatal error handle by /test/db.php'
);
}
mysql_select_db(
"test"
,
$connect
);
mysql_query(
"SET NAMES utf8"
,
$connect
);
$conn
= &
$connect
;
$db
= &
$connect
;
}
?>