• Java代码实现不同应用系统中数据同步程序

    系统A---->系统B。系统A表数据有新增、修改、删除时，会把这些发生记录的数据同步至系统B。

    实现思想：（一）、首先怎么确定系统A需要同步的表中数据发生了变化。

    （二）、什么时候需要同步这些有变化的数据。

    （三）、咋实现？

    第一步：使用SQL中的触发器记录数据变化

    触发器的作用是针对需要同步的表进行一个监控作用，当表数据发生了变化，触发器会立马检测到，进行数据记录，此时，我这里使用一个中间临时表进行记录。

     实现触发器的SQL：创建一个触发器名称为BIUDFER_YWCL_CASE_220905，需要针对哪张表进行检测———CCS_CASE_BASE_T。监控这张表的动作是update、insert、delete。

    数字1表示新增，2表示修改，3表示删除。主要是根据针对监控的表的主键进行记录，此表的主键是caseid。

    1. CREATE OR REPLACE TRIGGER BIUDFER_YWCL_CASE_220905
    2. after update or insert or delete on CCS_CASE_BASE_T
    3. FOR EACH ROW
    4. declare
    5. v_num number;
    6. BEGIN
    7.  CASE
    8.      WHEN inserting  THEN
    9. 		insert into EXCH_TRIGGER values(:new.caseid ,'1','CCS_CASE_BASE_T',to_char(list_id.nextval));           
    10.      WHEN UPDATING  THEN
    11.      	select count(1) into v_num from EXCH_TRIGGER where INFO_CTRLID=:new.caseid and LIST_TABLE='CCS_CASE_BASE_T' and INFO_CTRLSTATE in('1','2');
    12.      	if v_num=0 then
    13.         	insert into EXCH_TRIGGER values(:new.caseid ,'2','CCS_CASE_BASE_T',to_char(list_id.nextval));  
    14.         end if;
    15.      WHEN DELETING THEN
    16.      	select count(1) into v_num from EXCH_TRIGGER where INFO_CTRLID=:old.caseid and LIST_TABLE='CCS_CASE_BASE_T' and INFO_CTRLSTATE in('1');
    17.      	if v_num=1 then
    18.      		delete from EXCH_TRIGGER where INFO_CTRLID=:old.caseid and LIST_TABLE='CCS_CASE_BASE_T' and INFO_CTRLSTATE in('1');
    19.      	else     	
    20. 	     	select count(1) into v_num from EXCH_TRIGGER where INFO_CTRLID=:old.caseid and LIST_TABLE='CCS_CASE_BASE_T' and INFO_CTRLSTATE in('2');
    21. 	     	if v_num=1 then
    22. 		     	delete from EXCH_TRIGGER where INFO_CTRLID=:old.caseid and LIST_TABLE='CCS_CASE_BASE_T' and INFO_CTRLSTATE in('2');
    23. 		        insert into EXCH_TRIGGER values(:old.caseid ,'3','CCS_CASE_BASE_T',to_char(list_id.nextval)); 
    24. 	     	else     	
    25. 	        	insert into EXCH_TRIGGER values(:old.caseid ,'3','CCS_CASE_BASE_T',to_char(list_id.nextval));  
    26. 	        end if;
    27.      	end if;
    28.      END CASE;
    29. END;

    临时表EXCH_TRIGGER，建表语句

    1. CREATE TABLE "EXCH_TRIGGER"
    2. (
    3. "INFO_CTRLID" VARCHAR2(40),
    4. "INFO_CTRLSTATE" VARCHAR2(1),
    5. "LIST_TABLE" VARCHAR2(200),
    6. "LIST_ID" VARCHAR2(18) NOT NULL,
    7. NOT CLUSTER PRIMARY KEY("LIST_ID")) STORAGE(ON "MAIN", CLUSTERBTR) ;
    8. COMMENT ON TABLE "EXCH_TRIGGER" IS '导库控制表';
    9. COMMENT ON COLUMN "EXCH_TRIGGER"."INFO_CTRLSTATE" IS '操作数据库状态：1=insert,2=update,3=delete';
    10. COMMENT ON COLUMN "EXCH_TRIGGER"."LIST_TABLE" IS '操作表';

     临时表的序列，自增id。

    CREATE SEQUENCE "LIST_ID" INCREMENT BY 1 START WITH 1 MAXVALUE 999999999 MINVALUE 1 CACHE 20;

    第二步、Java程序实现

    代码中要随时知道表中有记录生成，就需要用到定时任务。所以就是编写定时任务。

    1. "1.0" encoding="UTF-8"?>
    2. <beans xmlns="http://www.springframework.org/schema/beans"
    3. 	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    4. 	xmlns:context="http://www.springframework.org/schema/context"
    5. 	xmlns:dwr="http://www.directwebremoting.org/schema/spring-dwr"
    6. 	xsi:schemaLocation="
    7. 		http://www.springframework.org/schema/beans 
    8. 		http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
    9. 		http://www.springframework.org/schema/context
    10. 		http://www.springframework.org/schema/context/spring-context-3.0.xsd 
    11. 		http://www.directwebremoting.org/schema/spring-dwr
    12.     	http://www.directwebremoting.org/schema/spring-dwr-3.0.xsd">
    13.     <bean id="quartz" lazy-init='false' class="org.springframework.scheduling.quartz.SchedulerFactoryBean">bean> 
    14. 	
    15. 	<bean id="MyDzfwQuartz" class="com.zrar.main.quartz.MyDzfwQuartz">bean>
    16.     	
    17.     <bean id="MyDzfwTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    18.         
    19.         <property name="targetObject">
    20.             <ref bean="MyDzfwQuartz"/>
    21.         property>
    22.         
    23.         <property name="targetMethod" value="dataChange">
    24.         property>
    25.     bean>
    26.     <bean id="MyDzfwTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    27. 		<property name="jobDetail" ref="MyDzfwTask" /> 
    28. 		
    29. 		<property name="cronExpression" value="0 * * * * ?" />
    30. 	bean>     
    31. 	
    32. 	<bean id="HljToGxbZskQuartz" class="com.zrar.main.quartz.HljToGxbZskQuartz">bean>
    33.     	
    34.     <bean id="HljToGxbZskDataChangeTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    35.         
    36.         <property name="targetObject">
    37.             <ref bean="HljToGxbZskQuartz"/>
    38.         property>
    39.         
    40.         <property name="targetMethod" value="dataChange">
    41.         property>
    42.     bean>
    43.     <bean id="HljToGxbZskDataChangeTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    44. 		<property name="jobDetail" ref="HljToGxbZskDataChangeTask" />
    45. 		
    46. 		<property name="cronExpression" value="0 * * * * ?" />
    47. 	bean>
    48. 	
    49. 	<bean id="HljToGxbQuartz" class="com.zrar.main.quartz.HljToGxbQuartz">bean>
    50.     	
    51.     <bean id="HljToGxbDataChangeTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    52.         
    53.         <property name="targetObject">
    54.             <ref bean="HljToGxbQuartz"/>
    55.         property>
    56.         
    57.         <property name="targetMethod" value="dataChange">
    58.         property>
    59.     bean>
    60.     <bean id="HljToGxbDataChangeTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    61. 		<property name="jobDetail" ref="HljToGxbDataChangeTask" />
    62. 		
    63. 		<property name="cronExpression" value="0 * * * * ?" />
    64. 	bean>
    65. 	
    66. 	<bean id="HljToGxbYYQuartz" class="com.zrar.main.quartz.HljToGxbYYQuartz">bean>
    67.     	
    68.     <bean id="HljToGxbYYDataChangeTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    69.         
    70.         <property name="targetObject">
    71.             <ref bean="HljToGxbYYQuartz"/>
    72.         property>
    73.         
    74.         <property name="targetMethod" value="dataChange">
    75.         property>
    76.     bean>
    77.     <bean id="HljToGxbYYDataChangeTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    78. 		<property name="jobDetail" ref="HljToGxbYYDataChangeTask" />
    79. 		
    80. 		<property name="cronExpression" value="0 * * * * ?" />
    81. 	bean>
    82. 	<bean id="myDzfwStartQuertz" lazy-init="true" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean" >
    83.        <property name="triggers">
    84.         <list>
    85. 	        <ref bean="MyDzfwTrigger"/>
    86. 	        <ref bean="HljToGxbDataChangeTrigger"/>
    87. 	        <ref bean="HljToGxbZskDataChangeTrigger"/>
    88. 	        <ref bean="HljToGxbYYDataChangeTrigger"/>
    89.         list>
    90.        property>
    91.    bean>                                                                                                                                                                                                                                                                                                            
    92. beans>

    定时任务完成后，就编写实现类与方法

    1. package com.zrar.main.quartz;
    2.  
    3. import com.alibaba.fastjson.JSONObject;
    4. import com.zrar.easyweb.core.util.PropertyManager;
    5. import com.zrar.easyweb.persistence.core.IBaseZrarDao;
    6. import com.zrar.main.zskbo.ZlInfoBO;
    7. import com.zrar.main.zskbo.ZlInfoNrBO;
    8. import com.zrar.main.util.HttpRequestUtil;
    9. import com.zrar.main.vo.ExchCaseTriggerVO;
    10.  
    11. import javax.annotation.Resource;
    12. import java.util.HashMap;
    13. import java.util.List;
    14. import java.util.Map;
    15.  
    16. public class HljToGxbZskQuartz {
    17.  
    18.     private static String HLJTOGXBZSK_URL= PropertyManager.getProperty("HLJTOGXBZSK_URL","application");
    19.  
    20.     //黑龙江知识库的ZL_INFO、ZL_INFO_NR
    21.     public static Map zsk= new HashMap();
    22.     static {
    23.         zsk.put("ZL_INFO", ZlInfoBO.class);
    24.         zsk.put("ZL_INFO_NR", ZlInfoNrBO.class);
    25.     }
    26.  
    27.     @Resource
    28.     private IBaseZrarDao daozsk;
    29.  
    30.     public void dataChange() {
    31.         String sql="select * from EXCH_TRIGGER order by to_number(LIST_ID)";
    32.         String sql1="delete from EXCH_TRIGGER where LIST_ID=?";
    33.         List ls= daozsk.getList(sql, ExchCaseTriggerVO.class);
    34.         for(ExchCaseTriggerVO vo:ls) {
    35.             String cid=vo.getInfoCtrlid();
    36.             String stat=vo.getInfoCtrlstate();
    37.             String table=vo.getListTable().toUpperCase();
    38.             String id=vo.getListId();
    39.             Map m1= new HashMap();
    40.             m1.put("cid", cid);
    41.             m1.put("stat", stat);
    42.             m1.put("table", table);
    43.             if("1".equals(stat)||"2".equals(stat)) {
    44.                 Object obj=daozsk.getBO(zsk.get(table), cid);
    45.                 m1.put("obj", obj);
    46.             }
    47.             String s= HttpRequestUtil.httpRequest(HLJTOGXBZSK_URL, m1);
    48.             JSONObject jo= JSONObject.parseObject(s);
    49.             String code=jo.getString("code");
    50.             if("0".equals(code)) {
    51.                 daozsk.update(sql1,id);
    52.             }
    53.         }
    54.     }
    55. }
    1. package com.zrar.main.util;
    2.  
    3. import java.nio.charset.StandardCharsets;
    4.  
    5. import org.apache.commons.lang.StringUtils;
    6. import org.apache.http.HttpResponse;
    7. import org.apache.http.client.HttpClient;
    8. import org.apache.http.client.methods.HttpPost;
    9. import org.apache.http.entity.StringEntity;
    10. import org.apache.http.impl.client.HttpClients;
    11. import org.apache.http.message.BasicHeader;
    12. import org.apache.http.util.EntityUtils;
    13.  
    14. import com.alibaba.fastjson.JSON;
    15. import com.zrar.easyweb.core.util.PropertyManager;
    16.  
    17. public class HttpRequestUtil {
    18. 	private static String url=PropertyManager.getProperty("JH_URL","application");
    19. 	/**   
    20.      * 发起https请求并获取结果   
    21.      *    
    22.      * @param requestUrl 请求地址   
    23.      * @param commoninfo 提交的数据   
    24.      * @return    
    25.      */    
    26. 	public static String httpRequest(String requestUrl, Object commoninfo){
    27. 		//返回的code -1 为失败
    28. 		String result = "{\"message\": \"%s\",\"code\": \"-1\"}";
    29. 		HttpClient client = HttpClients.createDefault();
    30. 		if(StringUtils.isEmpty(requestUrl)){
    31. 			requestUrl=url;
    32. 		}
    33. 		try {
    34. 			HttpPost post = new HttpPost(requestUrl);
    35. 			String materialInfo=JSON.toJSONString(commoninfo);
    36. 			post.setHeader(new BasicHeader("content-type", "text/plain;charset=utf-8"));
    37. 			//String body =materialInfo;
    38. 			post.setEntity(new StringEntity(materialInfo,StandardCharsets.UTF_8));
    39. 			//发送请求
    40. 			HttpResponse response = client.execute(post);
    41. 			//从response获取返回内容
    42. 			result= EntityUtils.toString(response.getEntity());
    43. 			System.out.println(result);
    44. 		}catch(Exception e){
    45. 			e.printStackTrace();
    46. 			result=String.format(result,"调用接口失败，异常信息："+e.toString());
    47. 		}
    48. 		return result;
    49. 	}
    50. }

    第三步、系统A数据推送到接口方处理数据，存储到系统B中。

    1. package com.zrar.main.blh;
    2.  
    3. import com.alibaba.fastjson.JSONObject;
    4. import com.zrar.easyweb.persistence.core.IBaseZrarDao;
    5. import com.zrar.easyweb.web.core.annotation.BLH;
    6. import com.zrar.easyweb.web.core.annotation.Mapping;
    7. import com.zrar.easyweb.web.core.event.IZrarRequest;
    8. import com.zrar.easyweb.web.core.event.IZrarResponse;
    9. import com.zrar.easyweb.web.core.event.impl.ZrarResponse;
    10. import com.zrar.main.bo.YwclCaseBO;
    11. import com.zrar.main.bo.YwclLzmxBO;
    12. import com.zrar.main.cxbo.YyfwtjBO;
    13. import com.zrar.main.zskbo.ZlInfoBO;
    14. import com.zrar.main.zskbo.ZlInfoNrBO;
    15.  
    16. import javax.annotation.Resource;
    17. import javax.servlet.http.HttpServletRequest;
    18. import java.io.BufferedReader;
    19. import java.io.IOException;
    20. import java.io.InputStream;
    21. import java.io.InputStreamReader;
    22. import java.util.Arrays;
    23. import java.util.HashMap;
    24. import java.util.Map;
    25.  
    26. @BLH("HljToGxbBLH")
    27. @Mapping("/hljToGxbBLH")
    28. public class HljToGxbBLH {
    29.  
    30. 	public static Map m= new HashMap();
    31. 	public static Map zsk= new HashMap();
    32. 	public static Map yyfwtj= new HashMap();
    33. 	static {
    34. 		m.put("CCS_CASE_TRANSFER_T", YwclLzmxBO.class);
    35. 		m.put("CCS_CASE_BASE_T", YwclCaseBO.class);
    36. 		zsk.put("ZL_INFO", ZlInfoBO.class);
    37. 		zsk.put("ZL_INFO_NR", ZlInfoNrBO.class);
    38. 		yyfwtj.put("TJ_YYFWFX", YyfwtjBO.class);
    39. 	}
    40. 	@Resource
    41. 	private IBaseZrarDao dao;
    42. 	@Resource
    43. 	private IBaseZrarDao daozsk;
    44. 	@Resource
    45. 	private IBaseZrarDao daocx;
    46.  
    47. 	/**
    48. 	 * 获取传输的数据
    49. 	 * @param request
    50. 	 * @return
    51. 	 */
    52. 	private String getQueryString(HttpServletRequest request){
    53. 		StringBuffer sb = new StringBuffer();
    54. 		InputStream is = null;
    55. 		InputStreamReader isr = null;
    56. 		BufferedReader br = null;
    57. 		try{
    58. 			is = request.getInputStream();
    59. 			isr = new InputStreamReader(is, "UTF-8");
    60. 			br = new BufferedReader(isr);
    61. 			String ss = "";
    62. 			while ((ss = br.readLine()) != null) {
    63. 				sb.append(ss);
    64. 			}
    65. 		}catch(Exception e){
    66. 			e.printStackTrace();
    67. 		}finally{
    68. 			if(br != null){
    69. 				try {
    70. 					br.close();
    71. 				} catch (IOException e) {
    72. 					e.printStackTrace();
    73. 				}
    74. 			}
    75. 			if(isr != null){
    76. 				try {
    77. 					isr.close();
    78. 				} catch (IOException e) {
    79. 					e.printStackTrace();
    80. 				}
    81. 			}
    82. 			if(is != null){
    83. 				try {
    84. 					is.close();
    85. 				} catch (IOException e) {
    86. 					e.printStackTrace();
    87. 				}
    88. 			}
    89. 		}
    90. 		return sb.toString();
    91. 	}
    92.  
    93. 	/**
    94. 	 * @Description:黑龙江工信部数据同步至部里（主表和流转明细表）
    95. 	 * CCS_CASE_TRANSFER_T  CCS_CASE_BASE_T
    96. 	 * @Author: simajilai
    97. 	 * @date: 2022/9/5 17:13
    98. 	 **/
    99. 	@Mapping("/hljToGxbDataChange")
    100. 	public IZrarResponse hljToGxbDataChange(IZrarRequest req) {
    101. 		IZrarResponse res = new ZrarResponse();
    102. 		HttpServletRequest request=req.getHttpServletRequest();
    103. 		//获取参数流
    104. 		String queryString=getQueryString(request);
    105. //		System.out.println(queryString);
    106. 		JSONObject jo= JSONObject.parseObject(queryString);
    107. 		String table=jo.getString("table");
    108. 		String stat=jo.getString("stat");
    109. 		String cid=jo.getString("cid");
    110. 		Class c=m.get(table);
    111. 		if("3".equals(stat)) {
    112. 			Object o=dao.getBO(c, cid);
    113. 			if(o!=null) {
    114. 				dao.deleteBO(o);
    115. 			}
    116. 		}else if("1".equals(stat)||"2".equals(stat)) {
    117. 			JSONObject jo1= jo.getJSONObject("obj");
    118. 			Object o=JSONObject.parseObject(jo1.toString(), c);
    119. 			dao.saveOrUpdateBO(Arrays.asList(o));
    120. 		}
    121. 		res.addResHtml("{\"code\":\"0\",\"message\":\"数据交互成功\"}");
    122. 		return res;
    123. 	}
    124. 	/**
    125. 	 * @Description:
    126. 	 * @Author: simajilai
    127. 	 * @date: 2022/9/6 8:41
    128. 	 **/
    129. 	@Mapping("/hljToGxbZskDataChange")
    130. 	public IZrarResponse hljToGxbZskDataChange(IZrarRequest req) {
    131. 		IZrarResponse res = new ZrarResponse();
    132. 		HttpServletRequest request=req.getHttpServletRequest();
    133. 		//获取参数流
    134. 		String queryString=getQueryString(request);
    135. //		System.out.println(queryString);
    136. 		JSONObject jo= JSONObject.parseObject(queryString);
    137. 		String table=jo.getString("table");
    138. 		String stat=jo.getString("stat");
    139. 		String cid=jo.getString("cid");
    140. 		Class c=zsk.get(table);
    141. 		if("3".equals(stat)) {
    142. 			Object o=daozsk.getBO(c, cid);
    143. 			if(o!=null) {
    144. 				daozsk.deleteBO(o);
    145. 			}
    146. 		}else if("1".equals(stat)||"2".equals(stat)) {
    147. 			JSONObject jo1= jo.getJSONObject("obj");
    148. 			Object o=JSONObject.parseObject(jo1.toString(), c);
    149. 			daozsk.saveOrUpdateBO(Arrays.asList(o));
    150. 		}
    151. 		res.addResHtml("{\"code\":\"0\",\"message\":\"数据交互成功\"}");
    152. 		return res;
    153. 	}
    154.  
    155. 	/**
    156. 	 * @Description:语音服务统计
    157. 	 * @Author: simajilai
    158. 	 * @date: 2022/9/6 16:06
    159. 	 **/
    160. 	@Mapping("/hljToGxbYYDataChange")
    161. 	public IZrarResponse hljToGxbYYDataChange(IZrarRequest req) {
    162. 		IZrarResponse res = new ZrarResponse();
    163. 		HttpServletRequest request=req.getHttpServletRequest();
    164. 		//获取参数流
    165. 		String queryString=getQueryString(request);
    166. //		System.out.println(queryString);
    167. 		JSONObject jo= JSONObject.parseObject(queryString);
    168. 		String table=jo.getString("table");
    169. 		String stat=jo.getString("stat");
    170. 		String cid=jo.getString("cid");
    171. 		Class c=yyfwtj.get(table);
    172. 		if("3".equals(stat)) {
    173. 			Object o=daocx.getBO(c, cid);
    174. 			if(o!=null) {
    175. 				daocx.deleteBO(o);
    176. 			}
    177. 		}else if("1".equals(stat)||"2".equals(stat)) {
    178. 			JSONObject jo1= jo.getJSONObject("obj");
    179. 			Object o=JSONObject.parseObject(jo1.toString(), c);
    180. 			daocx.saveOrUpdateBO(Arrays.asList(o));
    181. 		}
    182. 		res.addResHtml("{\"code\":\"0\",\"message\":\"数据交互成功\"}");
    183. 		return res;
    184. 	}
    185. }

    第四步、如果数据同步涉及到不同的库，什么应用库、查询库、知识库之类的，那么就需要配置数据源。。。

    1. "1.0" encoding="UTF-8"?>
    2. <beans xmlns="http://www.springframework.org/schema/beans"
    3. 	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
    4. 	xsi:schemaLocation="
    5. 		http://www.springframework.org/schema/beans 
    6. 		http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
    7. 		http://www.springframework.org/schema/context
    8. 		http://www.springframework.org/schema/context/spring-context-3.0.xsd ">
    9.  
    10. 	
    11. 	<context:property-placeholder location="classpath*:*.properties" />
    12. 	 
    13. 	
    14. 	<bean id="dataSourceTargetcx" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
    15. 		<property name="driverClassName" value="${cx.hibernate.connection.driver_class}">property>
    16. 		<property name="url" value="${cx.hibernate.connection.url}" />
    17. 		<property name="username"><value>${cx.hibernate.connection.username}value>property>
    18. 		<property name="password" value="${cx.hibernate.connection.password}"/>
    19. 	     <property name="filters"><value>statvalue>property>
    20. 	     <property name="maxActive"><value>50value>property>
    21. 	     <property name="initialSize"><value>1value>property>
    22. 	     <property name="maxWait"><value>60000value>property>
    23. 	     <property name="minIdle"><value>1value>property>
    24. 	     <property name="timeBetweenEvictionRunsMillis"><value>60000value>property>
    25. 	     <property name="minEvictableIdleTimeMillis"><value>300000value>property>
    26. 	     <property name="validationQuery"><value>SELECT 'x' from dualvalue>property>
    27. 	     <property name="testWhileIdle"><value>truevalue>property>
    28. 	     <property name="testOnBorrow"><value>falsevalue>property>
    29. 	     <property name="testOnReturn"><value>falsevalue>property>
    30. 	     <property name="poolPreparedStatements"><value>truevalue>property>
    31. 	     <property name="maxOpenPreparedStatements"><value>20value>property>
    32. 	 bean>
    33.  
    34. 	
    35. 	<bean id="sessionFactorycx"
    36. 		class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
    37. 		<property name="dataSource" ref="dataSourceTargetcx" />
    38. 		
    39. 		<property name="hibernateProperties">
    40. 			<props>
    41. 				<prop key="hibernate.dialect">${hibernate.dialect}prop>
    42. 				<prop key="hibernate.show_sql">${hibernate.show_sql}prop>
    43. 				<prop key="hibernate.format_sql">${hibernate.show_sql}prop>
    44. 				<prop key="hibernate.generate_statistics">falseprop>
    45. 			props>
    46. 		property>
    47. 		<property name="packagesToScan">
    48. 			<list>
    49. 			<value>com.zrar.main.cxbovalue>
    50. 			list>
    51. 		property>
    52. 	bean>
    53. 	
    54. 	
    55. 	<bean id="persistemce_oraclecx" class="org.springframework.orm.hibernate4.HibernateTemplate">
    56. 		<property name="sessionFactory" ref="sessionFactorycx">property>
    57. 	bean>
    58. 	<bean id="persistemce_oracle_jdbccx" class="org.springframework.jdbc.core.JdbcTemplate">
    59. 		<property name="dataSource" ref="dataSourceTargetcx">property>
    60. 	bean>
    61.  
    62.  
    63.  
    64. 	
    65. 	<bean id="sqlSessionFactorycx" class="org.mybatis.spring.SqlSessionFactoryBean">
    66. 		<property name="dataSource" ref="dataSourceTargetcx" />
    67. 		<property name="configLocation" value="classpath:mybatis-config.xml" />  
    68. 		<property name="mapperLocations" value="classpath*:mappers/**/*.xml">property>
    69. 	bean>
    70. 	
    71. 	<bean id="sqlSessioncx" class="org.mybatis.spring.SqlSessionTemplate">
    72. 	  <constructor-arg index="0" ref="sqlSessionFactorycx" />
    73. 	bean>
    74. 	
    75. 	
    76. 	<bean id="daocx" class="com.zrar.easyweb.persistence.core.factory.BaseZrarDaoFactory">
    77. 		<property name="hbTemplate" ref="persistemce_oraclecx" />
    78. 		<property name="jdbcTemplate" ref="persistemce_oracle_jdbccx" />
    79. 		<property name="sqlSession" ref="sqlSessioncx">property>
    80. 	bean>
    81. 	
    82.  
    83.  
    84. beans>

     配置多个数据源的文件application.properties。

    1. # [\u6570\u636E\u5E93\u914D\u7F6E]
    2. #hibernate.connection.driver_class=oracle.jdbc.driver.OracleDriver
    3. #hibernate.connection.url=jdbc:oracle:thin:@192.168.2.242:1521:ora242
    4. #hibernate.connection.username=gxb12381
    5. #hibernate.connection.password=gxb12381
    6. hibernate.connection.driver_class=dm.jdbc.driver.DmDriver
    7. hibernate.connection.url=jdbc:dm://192.168.2.240:5236
    8. hibernate.connection.username=hlj12381
    9. hibernate.connection.password=arkj123456
    10. hibernate.dialect=org.hibernate.dialect.OracleDialect
    11. hibernate.default_schema=gxb
    12. hibernate.show_sql=false
    13. hibernate.format_sql=true
    14.  
    15. cx.hibernate.connection.driver_class=dm.jdbc.driver.DmDriver
    16. cx.hibernate.connection.url=jdbc:dm://192.168.2.240:5236
    17. cx.hibernate.connection.username=hlj12381cx
    18. cx.hibernate.connection.password=arkj123456
    19.  
    20. zsk.hibernate.connection.driver_class=dm.jdbc.driver.DmDriver
    21. zsk.hibernate.connection.url=jdbc:dm://192.168.2.240:5236
    22. zsk.hibernate.connection.username=hljzsk
    23. zsk.hibernate.connection.password=arkj123456
    24.  
    25. # Redis settings    
    26. # server IP  
    27. redis.host=192.168.8.1
    28. # server port  
    29. redis.port=6379
    30. # use dbIndex  
    31. redis.database=0
    32. redis.password=
    33.  
    34. # \u63a7\u5236\u4e00\u4e2apool\u6700\u591a\u6709\u591a\u5c11\u4e2a\u72b6\u6001\u4e3aidle(\u7a7a\u95f2\u7684)\u7684jedis\u5b9e\u4f8b  
    35. redis.maxIdle=300
    36. # \u8868\u793a\u5f53borrow(\u5f15\u5165)\u4e00\u4e2ajedis\u5b9e\u4f8b\u65f6\uff0c\u6700\u5927\u7684\u7b49\u5f85\u65f6\u95f4\uff0c\u5982\u679c\u8d85\u8fc7\u7b49\u5f85\u65f6\u95f4(\u6beb\u79d2)\uff0c\u5219\u76f4\u63a5\u629b\u51faJedisConnectionException\uff1b  
    37. redis.maxWait=3000
    38. # \u5728borrow\u4e00\u4e2ajedis\u5b9e\u4f8b\u65f6\uff0c\u662f\u5426\u63d0\u524d\u8fdb\u884cvalidate\u64cd\u4f5c\uff1b\u5982\u679c\u4e3atrue\uff0c\u5219\u5f97\u5230\u7684jedis\u5b9e\u4f8b\u5747\u662f\u53ef\u7528\u7684  
    39. redis.testOnBorrow=true
    40. # \u6700\u5927\u8fde\u63a5\u6570
    41. redis.maxActive=300
    42.  
    43. JH_URL=http://127.0.0.1:8800/api/dataChange
    44. HLJTOGXB_URL=http://127.0.0.1:8800/hljToGxbBLH/hljToGxbDataChange
    45. HLJTOGXBZSK_URL=http://127.0.0.1:8800/hljToGxbBLH/hljToGxbZskDataChange
    46. HLJTOGXBYY_URL=http://127.0.0.1:8800/hljToGxbBLH/hljToGxbYYDataChange
    47.

  • 相关阅读:
    Docket安装nginx
    安装docker,打包jar包镜像文件，输出tar压缩包
    关于solidity解析abi方法，入参和结果字节码
    创建vue项目的安装汇总
    ORA-00257: Archiver error. Connect AS SYSDBA only until resolved错误解决
    el-form表单中不同数据类型对应的时间格式化和校验规则
    ParagonNTFS15.9.314新版Mac强大的读写工具
    0X03
    Redis常见基本类型(5)-List, Set
    开发《俄罗斯方块》的意义
  • 原文地址：https://blog.csdn.net/u011271164/article/details/126750027