关于java用Quertz定时进行数据库同步的简单操作
1. 首先需要添加定时器Quertz的依赖
<dependency><groupId>org.quartz-scheduler</groupId><artifactId>quartz</artifactId><version>2.3.0</version>
</dependency>
2. 定时器Quertz的xml文件配置
<!--定时器需要执行的代码(开始):每天凌晨2点执行该方法 同步数据--> <bean id="synchroEventReportTask" class="org.hyena.aers.task.SynchroEventReportTask"></bean> <!-- 设定执行代码中的具休方法 --> <bean id="synchroEventReportDetails" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"> <property name="targetObject"> <ref bean="synchroEventReportTask"/> </property> <property name="targetMethod"> <value>synchroEventReport</value> </property> </bean><bean id="synchroEventReportTriggers" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean"> <property name="jobDetail"> <ref bean="synchroEventReportDetails" /> </property> <property name="cronExpression"> <!--每天半夜12点30分执行一次:0 30 0 * * ? (注意日期域为0不是24)每天凌晨1点执行一次:0 0 1 * * ?每天上午10:15执行一次: 0 15 10 ? * * 或 0 15 10 * * ? 或 0 15 10 * * ? *每天中午十二点执行一次:0 0 12 * * ? 每天凌晨2点执行 --><value>0 0 02 * * ?</value></property></bean><!-- 定时器执行 同步事件上报数据 --> <bean id="synchroEventReport" class="org.springframework.scheduling.quartz.SchedulerFactoryBean"> <property name="triggers"> <list> <ref bean="synchroEventReportTriggers" /></list> </property> </bean> <!-- 定时器需要执行的代码(结束)-->
bean id="synchroEventReportTask"为class="org.hyena.aers.task.synchroEventReportTask"的封装,即自己后台中控制数据库同步的方法的封装名,后面的bean又以新的名称进行封装。
3.后台代码
主要就是连接双方的数据库,代码有详细注解,
需要导入的包我就只写关键的一些。
package org.hyena.aers.task;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import javax.annotation.Resource;@SuppressWarnings({ "unused", "rawtypes" })
public class SynchroEventReportTask{/**/* @function:每天凌晨2点同步*/@SuppressWarnings("unchecked")public void synchroEventReport() {Connection conn = null;Connection conn1 = null;Statement stmt = null;Statement stmt1 = null;ResultSet rs = null;ResultSet rs1 = null;StringBuffer sql = new StringBuffer();try {//开始进行需要获取数据的服务器连接//因为该项目使用的是sqlserver,所以用的是sqlserver驱动,如果是其他数据库的,请修改为对应的数据库驱动.Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");conn1 = DriverManager.getConnection("jdbc:sqlserver://192.168.10.135:1433(需要获取数据的服务器站点);DatabaseName=123(数据库名称);", "123(账号)","123(密码)");stmt = conn1.createStatement();//因为查询出多条记录,并且每条记录有多个字段,所以用List<Map<String, Object>>集合来存放数据List<Map<String, Object>> listMap = new ArrayList<Map<String, Object>>();//编写sql语句,获取自己需要取得数据,我这里写个简单示例sql.append("select username,userid from user");//执行查询的sqlrs = stmt.executeQuery(sql.toString());//循环遍历rs结果集,将结果集存放到list集合中while (rs.next()) {Map<String, Object> map = new HashMap<String, Object>();//将查询出的结果集中的数据分别用变量存放map.put("username", rs.getString("username"));map.put("userid ", rs.getString("userid "));listMap.add(map);}//关闭数据库连接conn1.close();stmt.close();rs.close();//将远程数据库的数据存放到listMap集合后开始连接需要同步数据到自己这里的数据库(同上,数据库不同,更换下驱动)Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");conn = DriverManager.getConnection("jdbc:sqlserver://192.168.10.187:1433;DatabaseName=123", "123","123");stmt1 = conn.createStatement();StringBuffer sql1 = new StringBuffer();StringBuffer sqlInsert = new StringBuffer();//如果从前面的数据库里取到了数据if(listMap.size()>0) {for (int i = 0; i < listMap.size(); i++) {String username = (String) listMap.get(i).get("username "); String userid = (String) listMap.get(i).get("userid ");//进行同步的sql语句sqlInsert.append("insert into user(username,userid) values('username', userid')");//查询数据是否重复sql1.append("select count(1) as t from user where userid = " + userid);rs1 = stmt1.executeQuery(sqlRepate.toString()); if (rs1.next()) {if ("0".equals(rs1.getString("zs"))) {//没有重复数据就运行插入语句stmt1.execute(sqlInsert.toString()); }}}}stmt1.close();} catch (Exception e) {e.printStackTrace();} finally {if (rs != null) {try {rs.close();} catch (SQLException e) {e.printStackTrace();}}if (rs1 != null) {try {rs1.close();} catch (SQLException e) {e.printStackTrace();}}if (stmt != null) {try {stmt.close();} catch (SQLException e) {e.printStackTrace();}}if (stmt1 != null) {try {stmt1.close();} catch (SQLException e) {e.printStackTrace();}}if (conn != null) {try {conn.close();} catch (SQLException e) {e.printStackTrace();}}if (conn1 != null) {try {conn1.close();} catch (SQLException e) {e.printStackTrace();}}
}
4 总结
虽然我这里写的比较简单,不过实际操作的时候还是有很多需要注意的地方。比如说数据库量大,参数过多的时候,就需要对参数一个个进行检验,因为只要一个字母写错就会导致程序报错而运行不了。所以大家在进行同步数据库之前需要把数据库进行下备份,这样就不会引起数据的错误。
关于java用Quertz定时进行数据库同步的简单操作相关推荐
- java 结构体_Java实现单链表的简单操作
文章目录 前言 一.基本实现思路 二.代码实现 1.定义结点类2.定义链表类3.测试调用4.结果 总结 前言 用Java实现单链表的简单操作,阅读本文和上一篇文章体会Java中类与C++中结构体指针的 ...
- java定时从数据库抓取数据库,java查询数据库java如何实现定时从数据库查询新增的数据?...
第一类,开个线程,定式扫描,好比每一分钟查询一次数据库,将前后数据做比对(比对方式能够正在java端先把第一次的数据存到一个调集外,然后每次查询调集之后,将两次的内容正在java端做比力) 第二类,正 ...
- postgresql数据库安装及简单操作
自从MySQL被Oracle收购以后,PostgreSQL逐渐成为开源关系型数据库的首选. 本文介绍PostgreSQL的安装和基本用法,供初次使用者上手.以下内容基于Debian操作系统,其他操作系 ...
- java jama包_java矩阵包jama的简单操作
本文转自http://www.cnblogs.com/zangbo/p/5622351.html 一.jama简介 Jama是一个基本的线性代数java包.包括一个基本的Matrix类和5个矩阵分解类 ...
- navicat导入sql数据库文件的简单操作步骤
目录 前言必读 一.概念 二.操作步骤 (一)新建连接 (二)新建数据库 (三)数据库导入sql文件 前言必读 读者手册(必读)_云边的快乐猫的博客-CSDN博客 一.概念 在很多项目当中都有sql文 ...
- php mysql数据库同步_实现MySQL数据库同步实例演示_MySQL
本次实验的主要目的是剖析配置MySQL(和PHP搭配之最佳组合) 数据库的主辅MySQL数据库同步的实际操作步骤,我前两天在相关网站看见的资料,觉得挺好,就拿出来供大家分享,开始具体的配置. 本次试验 ...
- mysql数据库的简单操作
一.启动mysql服务 1.启动mysql服务 win+R键打开运行,输入services.msc打开本地服务,找到MySQL,进行启动.停止等操作. 2.连接mysql 1.win+R键打开运行,输 ...
- Java中如何实现每天定时对数据库的操作
现在有一个很棘手的问题:客户要赠加一个功能,就是每天晚上11点要统计一下数据,并存到一个文件中,我试着用线程,但是总达不到理想的效果.请给点思路,多谢了. 我们的开发环境是tomcat和servlet ...
- MySQL数据库同步小工具(Java实现)
近期公司做个报表系统,为了报表系统中复杂的查询条件,不影响线上业务系统的使用,研究了一下MySQL数据库同步,下面用Java代码实现MySQL数据库同步,以便自己查阅! 数据库同步实现功能点: 1.支 ...
最新文章
- Android 使用Toolbar+DrawerLayout快速实现仿“知乎APP”侧滑导航效果
- sqlite3之基本操作(二)
- OpenGL样板程序,会转动的正方形
- HDU - 6071 Lazy Running 同余最短路 + 分层
- 【HDU - 1533】Going Home(网络流,二分图最优匹配,KM算法)
- 叠加卡片列表_使用PowerBI制作卡片图
- 微信群发助手怎么使用?微信群发助手怎么发?
- 360无线wifi路由器连接到服务器,luyou.360.cn如何登录360路由器
- python str center_Python str方法总结
- 微信小程序版本管理使用gitee
- 《小狗钱钱》阅读笔记
- 八、Linux全套大总结
- 从零开始搭建神经网络(五)卷积神经网络(CNN)
- 块储存、对象存储、文件存储的区别和联系
- php安装扩展错误:Cannot find config.m4. Make sure that you run /usr/local/bin/phpize in the top level sourc
- 听见丨小鹏汽车上​市量产车G3发布 英特尔与法拉利合作 将人工智能技术用于赛车运动
- 构建基于Jenkins + Github的持续集成环境
- 详解MapReduce实现数据去重与倒排索引应用场景案例
- 如果........
- 多语言跨境商城开发,源码无加密