Java代码之JDBC实现数据库之间定时的表格传输(由一个库读取到另一个库)实例,亲测有效
2018-05-11 16:55
1021 查看
package com.openup.system.service.imp;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;
import com.openup.system.service.DataReportService;
/**
* 定时任务 Service interface.
* @Table
*/
@Service
@Component
public class DataReportServiceImpl implements DataReportService{
/**
* @方法描述:定时数据导入到统计表
*/
@Override
// @Scheduled(cron = "0 0 3 * * ?") //每天3点钟执行方法
public void dataTransmission(){
//声明Connection对象
Connection con;
String driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
String url = "jdbc:sqlserver://*******; DatabaseName=****";
String user = "***";
String password = "***";
Connection con2;
String driver2 = "com.mysql.jdbc.Driver";
String url2 = "jdbc:mysql://***/****";
String user2 = "***";
String password2 = "***";
try {
//加载驱动程序
Class.forName(driver);
con = DriverManager.getConnection(url,user,password);
Class.forName(driver2);
con2 = DriverManager.getConnection(url2,user2,password2);
if(!con.isClosed()){
System.out.println("成功连接到数据库!");
}
//2.创建statement类对象,用来执行SQL语句!!
Statement statement = con.createStatement();
//要执行的SQL语句
String sql = "select ID,R_Index from Rpt_SpeedReport";
//要执行的SQL语句
String sql2 = "insert into DIC_INDEX(DI_ID,DI_NAME,DI_IUSER,DI_ITIME) values(?,?,?,?)";
//3.ResultSet类,用来存放获取的结果集!!
ResultSet rs = statement.executeQuery(sql);
PreparedStatement pst = con2.prepareStatement(sql2);
while(rs.next()){
System.out.print(rs.getString(1)+" ");
System.out.print(rs.getString(2)+"\n");
pst.setString(1,rs.getString(1));
pst.setString(2,rs.getString(2));
pst.setString(3,"1");
pst.setString(4,"201805111650");
pst.executeUpdate();
}
System.out.println("完成");
rs.close();
con.close();
con2.close();
}catch(ClassNotFoundException e) {
//数据库驱动类异常处理
System.out.println("对不起,找不到驱动程序!");
e.printStackTrace();
} catch(SQLException e) {
//数据库连接失败异常处理
e.printStackTrace();
}catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
}
public static void main(String[] args) {
DataReportServiceImpl a = new DataReportServiceImpl();
a.dataTransmission();
}
} 阅读更多
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;
import com.openup.system.service.DataReportService;
/**
* 定时任务 Service interface.
* @Table
*/
@Service
@Component
public class DataReportServiceImpl implements DataReportService{
/**
* @方法描述:定时数据导入到统计表
*/
@Override
// @Scheduled(cron = "0 0 3 * * ?") //每天3点钟执行方法
public void dataTransmission(){
//声明Connection对象
Connection con;
String driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
String url = "jdbc:sqlserver://*******; DatabaseName=****";
String user = "***";
String password = "***";
Connection con2;
String driver2 = "com.mysql.jdbc.Driver";
String url2 = "jdbc:mysql://***/****";
String user2 = "***";
String password2 = "***";
try {
//加载驱动程序
Class.forName(driver);
con = DriverManager.getConnection(url,user,password);
Class.forName(driver2);
con2 = DriverManager.getConnection(url2,user2,password2);
if(!con.isClosed()){
System.out.println("成功连接到数据库!");
}
//2.创建statement类对象,用来执行SQL语句!!
Statement statement = con.createStatement();
//要执行的SQL语句
String sql = "select ID,R_Index from Rpt_SpeedReport";
//要执行的SQL语句
String sql2 = "insert into DIC_INDEX(DI_ID,DI_NAME,DI_IUSER,DI_ITIME) values(?,?,?,?)";
//3.ResultSet类,用来存放获取的结果集!!
ResultSet rs = statement.executeQuery(sql);
PreparedStatement pst = con2.prepareStatement(sql2);
while(rs.next()){
System.out.print(rs.getString(1)+" ");
System.out.print(rs.getString(2)+"\n");
pst.setString(1,rs.getString(1));
pst.setString(2,rs.getString(2));
pst.setString(3,"1");
pst.setString(4,"201805111650");
pst.executeUpdate();
}
System.out.println("完成");
rs.close();
con.close();
con2.close();
}catch(ClassNotFoundException e) {
//数据库驱动类异常处理
System.out.println("对不起,找不到驱动程序!");
e.printStackTrace();
} catch(SQLException e) {
//数据库连接失败异常处理
e.printStackTrace();
}catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
}
public static void main(String[] args) {
DataReportServiceImpl a = new DataReportServiceImpl();
a.dataTransmission();
}
} 阅读更多
相关文章推荐
- Java代码之JDBC实现数据库之间定时的表格传输(由一个库读取到另一个库)实例
- java中JDBC实现往MySQL插入百万级数据的实例代码
- java实现定时器,定时修改数据库代码
- 博为峰Java技术题 ——JavaSE Java JDBC数据库查询代码实例
- java开发中JDBC连接数据库的代码实现与详解(转载)
- java 实现定时的方法及实例代码
- JDBC-实现Java代码连接数据库
- mini学生管理系统。。。全部代码,4个java文件放在同一个包下面即可。用JDBC调用数据库取出数据。
- java jdbc(三)应用实例--向数据库中存储,读取图片和文件
- JAVA读取Excel表格,建数据库建表,并生成java实体实例
- java实现一个扫描包的工具类实例代码
- Java实现嵌入式数据库(文本数据库)代码实例
- 用Java代码实现改变一个文本中的内容,即将一个文本里的内容修改内容,并存储到另一个文本中
- 用java的poi类读取一个excel表格的内容后再写入到一个新excel表格中的完整代码
- 使用监听器实现JAVA代码对数据库的定时操作,求大神帮帮忙!!!
- 话说Java jdbc数据库连接,从配置文件中读取连接基本信息实例
- java中JDBC实现往MySQL插入百万级数据的实例代码
- java SpringMVC中 POI读取数据库数据并写入Excel表格中,并实现下载功能
- java JDBC数据库连接封装和实例代码
- Java实现嵌入式数据库(文本数据库)代码实例