强制写库

chenlei2 · chenlei2 · commit ce08b8deba4a · 2018-05-01T09:37:22.000+08:00
diff --git a/spring-boot-mybatis-rw/spring-boot-mybatis-rw-starter/src/main/java/org/spring/boot/mybatis/rw/starter/datasource/DataSourceProxy.java b/spring-boot-mybatis-rw/spring-boot-mybatis-rw-starter/src/main/java/org/spring/boot/mybatis/rw/starter/datasource/DataSourceProxy.java
@@ -182,6 +182,7 @@ public Object invoke(Object proxy, Method method, Object[] args) throws Throwabl
 			// Invocation on ConnectionProxy interface coming in...
 			if (method.getName().equals("setTransactionIsolation") && args != null && (Integer) args[0] == Connection.TRANSACTION_SERIALIZABLE) {
 				 args[0] = defaultTransactionIsolation();
+				ConnectionHold.FORCE_WRITE.set(Boolean.TRUE);
 			}
 			if (method.getName().equals("equals")) {
 				// We must avoid fetching a target Connection for "equals".

Original file line number	Diff line number	Diff line change
`@@ -182,6 +182,7 @@ public Object invoke(Object proxy, Method method, Object[] args) throws Throwabl`
`182`	`182`	`// Invocation on ConnectionProxy interface coming in...`
`183`	`183`	`if (method.getName().equals("setTransactionIsolation") && args != null && (Integer) args[0] == Connection.TRANSACTION_SERIALIZABLE) {`
`184`	`184`	`args[0] = defaultTransactionIsolation();`
	`185`	`+ ConnectionHold.FORCE_WRITE.set(Boolean.TRUE);`
`185`	`186`	`}`
`186`	`187`	`if (method.getName().equals("equals")) {`
`187`	`188`	`// We must avoid fetching a target Connection for "equals".`