php实现mysql同步的实现方法
2015-01-24信息快讯网
由于公司的英文网站放置在美国,而这些网站的数据要与大陆的服务器数据同步。 同步时间在一天之内。
拿到需求之后,发现这两个网站的MYSQL数据库都不能远程访问(安全第一吧)。于是想起了 平时使用的CSV文件批量录入数据。于是尝试使用CSV导入导出。
导入到处框架如下:
1首先将数据导出成CSV的格式。
建立一文件,放置在中国服务器上:csv.php.其实就是一个导出函数,通过数据库,表名和SQL语句来获得数据。
csv.php
<?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, user,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 ,代码如下:
<?php /** * 从一个上传的文件中将数据导入到一个表中 * * @param string Mysql数据库的主机 * @param string 数据库名称 * @param string 数据库中的表名 * @param string 数据库的连接用户名 * @param string 数据库的连接密码 * @param string 数据库的表名 * * @return bool 是否执行成功 * * @access public */ function uploadFileOfCsv(host,db,user,pass,table,content){ mysql_connect(host, user,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("提取的数据如下:<br>".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 "<script language='javascript'>"; echo "alert('第".i."行的ID空,请检查!');"; echo "location.href=document.referrer;"; echo "</script>"; 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 <br>"; fwrite(fd,log); fclose(fd); } } ?>
3调用函数执行导出
在中国服务器上再建立一个 文件:test_export.php,调用前面的csv.php的函数,然后将数据转成CSV,然后临时存到一个表单的
textera中,注意表单提交的位置:
<?php require_once("csv.php"); host="localhost"; db="project"; user="root"; pass=""; //导出tb_contact表的数据为csv文件 filename = 'file4.csv'; cc=PMA_exportData( host,db,user,pass, filename,"tb_project_dvp", "", "test.php", "select * from tb_project_dvp") ; handle = fopen(filename, "rb"); contents = fread(handle, filesize (filename)); fclose(handle); ?> <form id="form1" name="form1" method="post" action="http://美国网站的地址/test2.php"> <p> <textarea name="textarea" cols="180" rows="30"><?php echo cc?></textarea> <input type="hidden" name="action" value="1"/> </p> <p> <input type="submit" name="Submit" value="提交"> </p> </form>
再在美国服务器上防置如下文件用于接受上传上来的数据,文件名为 test_import.php:
<?php require_once("csv.php"); require_once("import.php"); host="localhost"; db="wintopweb"; user="root"; pass=""; if(_POST['action']=="1"){ content=_POST['textarea']; echo uploadFileOfCsv(host,db,user,pass,"tb_project_dvp",content); } ?>
最后 利用Windows-xp/nt/03 控制面版中自带 任务计划,调度执行中国服务器test_export.php文件即可
php数据库抽象层 PDO
php cookies中删除的一般赋值方法
php中通过Ajax如何实现异步文件上传的代码实例
php 安全过滤函数代码
PHP 遍历文件实现代码
php中处理mysql_fetch_assoc返回来的数组 不用foreach----echo
php获取mysql数据库中的所有表名的代码
mysql_num_rows VS COUNT 效率问题分析
PHP导入Excel到MySQL的方法
在php和MySql中计算时间差的方法
PHPwind整合最土系统用户同步登录实现方法
php 3行代码的分页算法(求起始页和结束页)
php 魔术方法使用说明
php foreach、while性能比较
php侧拉菜单 漂亮,可以向右或者向左展开,支持FF,IE
php 数学运算验证码实现代码
用mysql触发器自动更新memcache的实现代码
基于OpenCV的PHP图像人脸识别技术
PHP5 操作MySQL数据库基础代码
从Web查询数据库之PHP与MySQL篇
php Sql Server连接失败问题及解决办法
php与php MySQL 之间的关系
PHP源码之 ext/mysql扩展部分
如何做到多PY料的同步