From 6c2937cd427423d6ffde854890869eccdddfab37 Mon Sep 17 00:00:00 2001 From: wenshao Date: Sun, 17 Jul 2011 09:09:50 +0000 Subject: [PATCH] =?UTF-8?q?=E6=94=AF=E6=8C=81HA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit git-svn-id: http://code.alibabatech.com/svn/druid/trunk@462 b9813039-fb51-4c41-a8b9-e21c2acb5095 --- src/main/java/com/alibaba/druid/pool/ha/HAConnection.java | 2 +- src/main/java/com/alibaba/druid/pool/ha/HADataSource.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/alibaba/druid/pool/ha/HAConnection.java b/src/main/java/com/alibaba/druid/pool/ha/HAConnection.java index c9e33ea3e2..5c8cb2dbdb 100644 --- a/src/main/java/com/alibaba/druid/pool/ha/HAConnection.java +++ b/src/main/java/com/alibaba/druid/pool/ha/HAConnection.java @@ -54,7 +54,7 @@ public class HAConnection extends WrapperAdapter implements Connection, Connecti public void checkConnection(String sql) throws SQLException { if (conn == null) { - conn = haDataSource.getConnectionInternal(id); + conn = haDataSource.getConnectionInternal(id, sql); } if (autoCommit != null) { diff --git a/src/main/java/com/alibaba/druid/pool/ha/HADataSource.java b/src/main/java/com/alibaba/druid/pool/ha/HADataSource.java index c52d9cd663..626d4ce0d0 100644 --- a/src/main/java/com/alibaba/druid/pool/ha/HADataSource.java +++ b/src/main/java/com/alibaba/druid/pool/ha/HADataSource.java @@ -36,7 +36,7 @@ public class HADataSource extends MultiDataSource implements DataSource { return statementIdSeed.getAndIncrement(); } - public Connection getConnectionInternal(int requestNumber) throws SQLException { + public Connection getConnectionInternal(int connectionId, String sql) throws SQLException { int tryCount = 0; for (;;) { @@ -46,7 +46,7 @@ public class HADataSource extends MultiDataSource implements DataSource { throw new SQLException("can not get connection, no availabe datasources"); } - int index = requestNumber % size; + int index = connectionId % size; DruidDataSource dataSource = null;