php实现mysql同步的实现方法
前端之家收集整理的这篇文章主要介绍了
php实现mysql同步的实现方法，
前端之家小编觉得挺不错的，现在分享给大家，也给大家做个参考。
拿到需求之后，发现这两个网站的MysqL数据库都不能远程访问(安全第一吧)。于是想起了 平时使用的CSV文件批量录入数据。于是
尝试使用CSV导入导出。
导入到处框架如下：
1首先将数据导出成CSV的格式。
建立一文件，放置在中国服务器上：csv.PHP.其实就是一个导出函数，通过数据库，表名和sql语句来获得数据。
csv.PHP
<div class="codetitle"><a style="CURSOR: pointer" data="19967" class="copybut" id="copybut19967" onclick="doCopy('code19967')"> 代码如下:
<div class="codebody" id="code19967">
<?
PHP /
输出一个数据库中的表到一个CSV文件中
@param string MysqL数据库的主机
@param string 数据库名称
@param string 数据库中的表名
@param string 数据库的连接用户名
@param string 数据库的连接密码
@param string 数据库的表名
@param string 数据库的
@param string 错误页面
@param string sql语句
@return text 返回CSV格式的内容
@access public
/
function PMA_exportData(host,db,user,pass,filename,table,crlf,error_url,sql_query) {
what="csv";
csv_terminated=" ";
csv_separator=",";
csv_enclosed=" ";
csv_escaped="";
MysqL_connect(host,pass) or die("不能连接数据库，错误代码如下：" . MysqL_error());
MysqL_select_db(db);
result = MysqL_query(sql_query);
fields_cnt = MysqL_num_fields(result);
cc="";
//fp = fopen(filename,'w');
// 格式化数据
while (row = MysqL_fetch_row(result)) {
schema_insert = '';
for (j = 0; j < fields_cnt; j++) {
if (!isset(row[j]) || is_null(row[j])) {
schema_insert .="NULL"; //用什么来替换空值
} elseif (row[j] == '0' || row[j] != '') {
// loic1 :用引号包含字段值
if (csv_enclosed == '') {
schema_insert .= row[j];
} else {
schema_insert .= csv_enclosed
. str_replace(csv_enclosed,csv_escaped . csv_enclosed,row[j])
. csv_enclosed;
}
} else {
schema_insert .= '';
}
if (j < fields_cnt-1) {
schema_insert .= csv_separator;
}
} // end for
// fwrite(fp,schema_insert . csv_terminated);
cc.=schema_insert . csv_terminated;
} // end while
MysqL_free_result(result);
// fclose(fp);
return cc;
}
?>
2.将CSV格式的
内容导入到表中
在美国服务器上建立个导入的
文件，放置：import.
PHP,
代码如下：
<div class="codetitle">
<a style="CURSOR: pointer" data="11681" class="copybut" id="copybut11681" onclick="doCopy('code11681')"> 代码如下: <div class="codebody" id="code11681">
<?
PHP /
从一个上传的文件中将数据导入到一个表中
@param string MysqL数据库的主机
@param string
数据库名称 @param string 数据库中的表名
@param string
数据库的连接
用户名 @param string 数据库的连接密码
@param string
数据库的表名
@return bool 是否执行成功
@access public
/
function uploadFileOfCsv(host,content){
MysqL_connect(host,pass) or die("不能连接数据库，错误代码如下：" . MysqL_error());
MysqL_select_db(db);
result = MysqL_query("select from table");
fields_cnt =
MysqL_num_fields(result);
test2=array(array());
rownum=0;
log("
提取的数据如下：
".content);
fd1 = fopen ("C:test.csv",'a');
fwrite(fd1,content);
fclose(fd1);
fp = fopen("C:test.csv","r");
while (buffer = fgets(fp,4096))
{
i++;
tmp_arr = explode(",",buffer);
if(trim(tmp_arr[0]) == ""){
echo "";
exit;
}
query = "INSERT INTO db.table";
query .=" values ( ";
for(q=0;q<fields_cnt;q++){
if(q==fields_cnt-1){
tmp=tmp_arr[q];
query.="'tmp');";
}else{
tmp=tmp_arr[q];
query.="'tmp',";
}
}//end for(q=0;
log2(query);
MysqL_query(query);
}
fclose(fp);
return "OK";
unlink("C:test.csv");
}
function log2(event = null){
//global db;
// global login;
if(LOG_ENABLED){
now = date("Y-M-d H:i:s");
fd = fopen ("C:log.html",'a');
log = now." "._SERVER["REMOTE_ADDR"] ." - event
";
fwrite(fd,log);
fclose(fd);
}
}
?>
：test_export.
前面的csv.
