⼀台MySql服务器不同数据库之间数据同步_解决⽅案（Java）原创！
前提：⽬前MySql数据库中有两个数据库，名称分别为：db01和db02。db01中的⼈员表叫t_user_info；db02中的⼈员表叫t_user。需求：将表t_user_info(id,name,type,content,createtime)的数据导⼊到表t_use( userid,username,usertype, usercontent,user createtime)中。
第⼀步：运⽤JDBC建⽴数据源
/**
* JDBC连接数据库（db01） bgy
* @return Connection
*/
public static Connection getConnection01() throws SQLException,java.lang.ClassNotFoundException
{
/
/第⼀步：加载MySQL的JDBC的驱动
Class.forName("sql.jdbc.Driver");
//取得连接的url，能访问MySQL数据库的⽤户名，密码；db01：数据库名
String url = "jdbc:mysql://192.168.88.1:3306/db01";
String username = "bgy01";
String password = "123456";
//第⼆步：创建与MySQL数据库的连接类的实例
Connection con01 = (Connection) Connection(url, username, password);
return con01;
}
/**
* JDBC连接数据库（db02） bgy
* @return Connection
*/
public static Connection getConnection02() throws SQLException,java.lang.ClassNotFoundException
{
//第⼀步：加载MySQL的JDBC的驱动
Class.forName("sql.jdbc.Driver");
//取得连接的url，能访问MySQL数据库的⽤户名，密码；db02：数据库名
碎龙String url = "jdbc:mysql://192.168.88.2:3306/db02";
String username = "bgy02";
String password = "123456";上网的好处
//第⼆步：创建与MySQL数据库的连接类的实例
Connection con02 = (Connection) Connection(url, username, password);
return con02;
}
第⼆步：同步数据实现详细（⽅法dSynchronous()）
/**
* 同步数据 bgy
* @return String
* @throws ClassNotFoundException
* @throws SQLException
*/
public String dSynchronous() throws SQLException, ClassNotFoundException
{
//前台传来值
String param = Parameter("param");
try
{
//设置“db01”数据源
Connection con01 = getConnection01();
Statement sql_statement01 = (Statement) ateStatement();
//设置“db02”数据源
Connection con02 = getConnection02();
Statement sql_statement02 = (Statement) ateStatement();
//⼈员信息1
if("1".equals(param))
{
//定位⾄db01
uteUpdate("use db01");
//定位⾄db02
uteUpdate("use db02");
//删除“db02”⽤户表t_user的数据
String query1 = "TRUNCATE TABLE t_user;"; //TRUNCATE⽐DELETE效率⾼太多
uteUpdate(query1);
String query2 = "ALTER TABLE t_user AUTO_INCREMENT=1;"; //⾃增序列设为1
uteUpdate(query2);
//向“db02”⽤户表t_user插⼊数据
int tag = uteUpdate("INSERT INTO db02.t_user (id, name,type,content,createtime) SELECT userid, username, usertype, usercontent, usercreatetime FROM db01.t_user_info");
String jsondata = null;
if(tag > 0)
{
jsondata = "{'flag':'ok'}";
}
else
{
jsondata = "{'flag':'error'}";
}
}
//“其余”
if("2".equals(param))
新年贺卡怎么做{
//业务逻辑代码
}
//“其余”
else
{
//业务逻辑代码
}
//关闭数据源
sql_statement01.close();
干什么赚钱最快conWly.close();
sql_statement02.close();
conYxl.close();
}
catch(java.lang.ClassNotFoundException e)
{
/
/加载JDBC错误，所要⽤的驱动没有到
王者荣耀为什么改不了名字//其他错误
}
catch(SQLException ex)
{
//显⽰数据库连接错误或查询错误
return SUCCESS;
}
版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。
发表评论