当前位置：首页 → 问答吧 → MYSQL5触发器做数据同步

MYSQL5触发器做数据同步

时间：2006-12-24

来源：互联网

这几天公司要用触发器作数据同步。数据表有100多张，还不把人累死。所以写了个触发器的自动生成程序：
呵呵：把数据库名表名输入就OK了，生成的代码直接到mysql编译器里运行，触发器就上去了

[群号18255508] 大家一起来研究PHP一起工作

<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head>
<meta http-equiv="Content-Type" c />
<title>无标题文档</title>
<style type="text/css">

</style>
<script language="javascript">

function res(){
document.getElementById("tab2").value = "pre_"+document.getElementById("tab1").value;
}
</script>
</head>

<body>
<form action="#" method="post" name="form1" target="_blank" id="form1">
  数据库名
<input name="dbTbaleName" type="text" id="dbTbaleName" value="dbname" />
<br>
  驱动表
  <input name="tab1" type="text" id="tab1" /> <br>
  被触发的表
  <input name="tab2" type="text" id="tab2"  /><br>
  <input type="submit" name="Submit" value="提交" /><br>
</form>
<?php
/**
* -------------------文档注释------------------------------------------
* 作者*达达*QQ 85089479*email  [email protected]*
* 创建时间*2006-012-*
* 功能描述*数据同步触发器生成工具*
* 最后修改时间*2006-12-*
* -------------------------------------------------------------------
*/
$dbName = "localhost"; //主机名
$dbUserName = "root"; // 用户名
$dbpassword = "admin"; //密码
$dbTbaleName = $_POST['dbTbaleName']; //数据库名
$tab1 = $_POST['tab1']; //执行的表
$tab2 = $_POST['tab2']; //被触发的表
$conn = mysql_connect($dbName, $dbUserName, $dbpassword) or die("请检查你的主机名数据库用户名和密码");
mysql_select_db($dbTbaleName, $conn) or die("数据库还没有连接");
mysql_select_db("$dbTbaleName");
$result = mysql_query("select * from $tab1")//得到表查询的结果
or die("Query failed: " . mysql_error());
echo("<br>");
$i = 1;//这里是为了替换最后一个列名的，符号所以=1 <>0
echo "create trigger " . $tab1 . "_insert BEFORE INSERT on $tab1<br>";
echo "for each row BEGIN<br>";
echo "INSERT INTO $tab2 SET<br>";
while ($i < mysql_num_fields($result)){//列的数量的循环

   $meta = mysql_fetch_field($result);//得到一个关于列的信息的对角
   if (!$meta){
      echo "No information available<br />\n";
      }
//下面输出的是触发器程序列信息
   echo "<pre>
  `$meta->name`=NEW.$meta->name,
</pre>";
   $i++;
   }
$meta = mysql_fetch_field($result);
echo "<pre>
  `$meta->name`=NEW.$meta->name;
</pre>";
mysql_free_result($result);
echo("END;");

// -----------------------------------------------------------------
$result = mysql_query("select * from $tab1")
or die("Query failed: " . mysql_error());
$i = 1;
if ($i < mysql_num_fields($result)){

   $meta = mysql_fetch_field($result);

   // -----------------------------------------------------------------
/**
   * create trigger `tri_del` BEFORE DELETE on `aaa`
   * for each row BEGIN
   * DELETE FROM bbb WHERE id =OLD.id;
   */
echo("<br>");

   echo "create trigger " . $tab1 . "_del BEFORE DELETE on $tab1<br>";
   echo "for each row BEGIN<br>";

   echo "DELETE FROM $tab2 WHERE $meta->name =OLD.$meta->name;<br>";
   echo("END;");

   }
// -----------------------------------------------------------------
echo("<br>");
/**
* create trigger `up_date` BEFORE UPDATE on `aaa`
* for each row BEGIN
* UPDATE bbb set a1 = new.a1 , a2=new.a2 where id = new.id;
* END;
*/
$result = mysql_query("select * from $tab1")
or die("Query failed: " . mysql_error());
/**
* get column metadata
*/
$i = 1;
echo "create trigger " . $tab1 . "_update BEFORE UPDATE on $tab1<br>";
echo "for each row BEGIN<br>";
echo "UPDATE $tab2 SET<br>";
while ($i < mysql_num_fields($result)){

   $meta = mysql_fetch_field($result);
   if (!$meta){
      echo "No information available<br />\n";
      }
   echo "<pre>
  `$meta->name`=NEW.$meta->name,
</pre>";
   $i++;
   }
$meta = mysql_fetch_field($result);
echo "<pre>
  `$meta->name`=NEW.$meta->name
</pre>";
mysql_free_result($result);
// -----------------------------
$result = mysql_query("select * from $tab1")
or die("Query failed: " . mysql_error());
$i = 1;
if ($i < mysql_num_fields($result)){

   $meta = mysql_fetch_field($result);
   echo("where $meta->name = new.$meta->name;<br>");

   echo("END;");

   }
?>
[群号18255508] 大家一起来研究PHP一起工作

</body>
</html>

[ 本帖最后由 PHP.CHINA 于 2007-3-22 00:04 编辑 ]

作者: PHP.CHINA 发布时间: 2006-12-24

看看

作者: 点点浪发布时间: 2007-01-18

好东东

作者: dzjzmj 发布时间: 2007-01-18

楼主把代码加个亮吧.

作者: hy0kl 发布时间: 2007-03-06

因�槭颤N不使用 MySQL Replication 呢 ?

作者: wesley305 发布时间: 2007-03-17

:) 学习一下

作者: 特蓝克斯发布时间: 2007-03-18

收藏了。
又一个PHP群。
:)