频道导航

php实现mysql同步的实现方法

2018-12-30 PHP 前端之家

前端之家收集整理的这篇文章主要介绍了php实现mysql同步的实现方法，前端之家小编觉得挺不错的，现在分享给大家，也给大家做个参考。

拿到需求之后，发现这两个网站的MysqL 数据库都不能远程访问(安全第一吧)。于是想起了平时使用的CSV文件批量录入数据。于是 @H_4030@尝试使用CSV导入导出。 @H4030@导入到处框架如下： @H4030@1首先将数据导出成CSV的格式。 @H403_0@建立一文件，放置在中国服务器上：csv.PHP.其实就是一个导出函数，通过数据库，表名和sql语句来获得数据。 @H_403_0@csv.PHP @H_403_0@<div class="codetitle"><a style="CURSOR: pointer" data="19967" class="copybut" id="copybut19967" onclick="doCopy('code19967')"> 代码如下:

<div class="codebody" id="code19967"> @H_403_0@<?PHP @H_4030@/** @H403_0@ 输出一个数据库中的表到一个CSV文件中 @H_403_0@ @H_403_0@ @param string MysqL 数据库的主机 @H_403_0@ @param string 数据库名称 @H_403_0@ @param string 数据库中的表名 @H_403_0@ @param string 数据库的连接用户名 @H_403_0@ @param string 数据库的连接密码 @H_403_0@ @param string 数据库的表名 @H_403_0@ @param string 数据库的 @H_403_0@ @param string 错误页面 @H_403_0@ @param string sql语句 @H_403_0@ @H_403_0@ @return text 返回CSV格式的内容 @H_403_0@ @H_4030@* @access public @H4030@*/ @H403_0@function PMA_exportData(host,db,user,pass,filename,table,crlf,error_url,sqlquery) { @H4030@what="csv"; @H403_0@csvterminated=" "; @H403_0@csvseparator=","; @H403_0@csvenclosed=" "; @H403_0@csvescaped=""; @H403_0@MysqL_connect(host,pass) or die("不能连接数据库，错误代码如下：" . MysqLerror()); @H403_0@MysqL_selectdb(db); @H403_0@result = MysqL_query(sqlquery); @H403_0@fields_cnt = MysqL_numfields(result); @H4030@cc=""; @H4030@//fp = fopen(filename,'w'); @H4030@// 格式化数据 @H403_0@while (row = MysqL_fetchrow(result)) { @H403_0@schemainsert = ''; @H403_0@for (j = 0; j < fieldscnt; j++) { @H403_0@if (!isset(row[j]) || isnull(row[j])) { @H403_0@schemainsert .="NULL"; //用什么来替换空值 @H4030@} elseif (row[j] == '0' || row[j] != '') { @H4030@// loic1 :用引号包含字段值 @H403_0@if (csvenclosed == '') { @H403_0@schemainsert .= row[j]; @H4030@} else { @H403_0@schema_insert .= csvenclosed @H403_0@. str_replace(csv_enclosed,csv_escaped . csvenclosed,row[j]) @H403_0@. csvenclosed; @H4030@} @H4030@} else { @H403_0@schemainsert .= ''; @H4030@} @H403_0@if (j < fieldscnt-1) { @H403_0@schema_insert .= csvseparator; @H4030@} @H4030@} // end for @H403_0@// fwrite(fp,schema_insert . csvterminated); @H403_0@cc.=schema_insert . csvterminated; @H4030@} // end while @H403_0@MysqL_freeresult(result); @H4030@// fclose(fp); @H4030@return cc; @H4030@} @H4030@?> @H4030@

@H403_0@2.将CSV格式的内容导入到表中 @H_403_0@在美国服务器上建立个导入的文件，放置：import.PHP,代码如下： @H_403_0@<div class="codetitle"><a style="CURSOR: pointer" data="11681" class="copybut" id="copybut11681" onclick="doCopy('code11681')"> 代码如下:

<div class="codebody" id="code11681"> @H_403_0@<?PHP @H_4030@/** @H403_0@ 从一个上传的文件中将数据导入到一个表中 @H_403_0@ @H_403_0@ @param string MysqL 数据库的主机 @H_403_0@ @param string 数据库名称 @H_403_0@ @param string 数据库中的表名 @H_403_0@ @param string 数据库的连接用户名 @H_403_0@ @param string 数据库的连接密码 @H_403_0@ @param string 数据库的表名 @H_4030@* @H4030@* @return bool 是否执行成功 @H4030@* @H4030@* @access public @H4030@*/ @H4030@function uploadFileOfCsv(host,content){ @H403_0@MysqL_connect(host,pass) or die("不能连接数据库，错误代码如下：" . MysqLerror()); @H403_0@MysqL_selectdb(db); @H403_0@result = MysqLquery("select * from table"); @H403_0@fields_cnt = MysqL_numfields(result); @H4030@test2=array(array()); @H4030@rownum=0; @H403_0@log("提取的数据如下：
".content); @H_4030@fd1 = fopen ("C:test.csv",'a'); @H4030@fwrite(fd1,content); @H4030@fclose(fd1); @H4030@fp = fopen("C:test.csv","r"); @H4030@while (buffer = fgets(fp,4096)) @H4030@{ @H4030@i++; @H403_0@tmparr = explode(",",buffer); @H403_0@if(trim(tmparr[0]) == ""){ @H4030@echo ""; @H4030@exit; @H4030@} @H4030@query = "INSERT INTO db.table"; @H4030@query .=" values ( "; @H403_0@for(q=0;q<fieldscnt;q++){ @H403_0@if(q==fieldscnt-1){ @H403_0@tmp=tmparr[q]; @H4030@query.="'tmp');"; @H4030@}else{ @H403_0@tmp=tmparr[q]; @H4030@query.="'tmp',"; @H4030@} @H4030@}//end for(q=0; @H4030@log2(query); @H403_0@MysqLquery(query); @H4030@} @H4030@fclose(fp); @H4030@return "OK"; @H4030@unlink("C:test.csv"); @H4030@} @H4030@function log2(event = null){ @H4030@//global db; @H4030@// global login; @H403_0@if(LOGENABLED){ @H4030@now = date("Y-M-d H:i:s"); @H4030@fd = fopen ("C:log.html",'a'); @H403_0@log = now." "._SERVER["REMOTEADDR"] ." - event
"; @H4030@fwrite(fd,log); @H4030@fclose(fd); @H4030@} @H4030@} @H4030@?> @H4030@

@H403_0@3调用函数执行导出 @H_403_0@在中国服务器上再建立一个文件：test_export.PHP,调用前面的csv.PHP的函数，然后将数据转成CSV，然后临时存到一个表单的 @H_4030@textera中，注意表单提交的位置： @H403_0@<div class="codetitle"><a style="CURSOR: pointer" data="89655" class="copybut" id="copybut89655" onclick="doCopy('code89655')"> 代码如下:

<div class="codebody" id="code89655"> @H_403_0@<?PHP @H_403_0@require_once("csv.PHP"); @H_4030@host="localhost"; @H4030@db="project"; @H4030@user="root"; @H4030@pass=""; @H403_0@//导出tb_contact表的数据为csv文件 @H_4030@filename = 'file4.csv'; @H403_0@cc=PMA_exportData( host,"tb_project_dvp","","test.PHP","select * from tb_projectdvp") ; @H4030@handle = fopen(filename,"rb"); @H4030@contents = fread(handle,filesize (filename)); @H4030@fclose(handle); @H4030@?> @H403_0@<form id="form1" name="form1" method="post" action="http://美国网站的地址/test2.PHP"> @H_4030@

@H4030@<textarea name="textarea" cols="180" rows="30"><?php echo cc?> @H4030@<input type="hidden" name="action" value="1"/> @H4030@

@H4030@

@H4030@<input type="submit" name="Submit" value="提交"> @H4030@

@H4030@ @H4030@

@H403_0@再在美国服务器上防置如下文件用于接受上传上来的数据，文件名为 test_import.PHP： @H_403_0@<div class="codetitle"><a style="CURSOR: pointer" data="29175" class="copybut" id="copybut29175" onclick="doCopy('code29175')"> 代码如下:

<div class="codebody" id="code29175"> @H_403_0@<?PHP @H_403_0@require_once("csv.PHP"); @H_403_0@require_once("import.PHP"); @H_4030@host="localhost"; @H4030@db="wintopweb"; @H4030@user="root"; @H4030@pass=""; @H403_0@if(POST['action']=="1"){ @H403_0@content=POST['textarea']; @H4030@echo uploadFileOfCsv(host,content); @H4030@} @H4030@?> @H4030@ @H403_0@最后利用Windows-xp/nt/03 控制面版中自带任务计划，调度执行中国服务器test_export.PHP 文件即可

mysql同步 php