Alawn/Druid
1
0
Fork 0
mirror of https://github.com/alibaba/druid.git synced 2023-03-04 19:17:16 +00:00
Code Issues Releases Wiki Activity

jtds xa support 1.2.x & 1.3.0

Browse Source
This commit is contained in:
wenshao
2012-12-23 15:00:51 +08:00
parent dc16f4af1a
commit c56c8530ae
2 changed files with 36 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/alibaba/druid/pool/xa/JtdsXAResource.java
+25 -3
View File
@@ -15,25 +15,47 @@
*/
package com.alibaba.druid.pool.xa;
import java.lang.reflect.Method;
import java.sql.Connection;
import javax.transaction.xa.XAException;
import javax.transaction.xa.XAResource;
import javax.transaction.xa.Xid;
import net.sourceforge.jtds.jdbc.ConnectionJDBC2;
import net.sourceforge.jtds.jdbc.XASupport;
import com.alibaba.druid.support.logging.Log;
import com.alibaba.druid.support.logging.LogFactory;
public class JtdsXAResource implements XAResource {
private final static Log LOG = LogFactory.getLog(JtdsXAResource.class);
private final Connection connection;
private final JtdsXAConnection xaConnection;
private final String rmHost;
private String rmHost;
private static Method method;
public JtdsXAResource(JtdsXAConnection xaConnection, Connection connection){
this.xaConnection = xaConnection;
this.connection = connection;
rmHost = ((ConnectionJDBC2) connection).getRmHost();
if (method == null) {
try {
method = connection.getClass().getMethod("getRmHost");
} catch (Exception e) {
LOG.error("getRmHost method error", e);
}
}
if (method != null) {
try {
rmHost = (String) method.invoke(connection);
} catch (Exception e) {
LOG.error("getRmHost error", e);
}
}
}
protected JtdsXAConnection getResourceManager() {