lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

DataJdbcSource优化

Browse Source
This commit is contained in:
redkale
2023-12-04 12:10:54 +08:00
parent aeafac22b0
commit c62b55fea4
1 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
src/main/java/org/redkale/source/DataJdbcSource.java
View File

@@ -35,9 +35,9 @@ import org.redkale.util.*;
@ResourceType(DataSource.class) @ResourceType(DataSource.class)
public class DataJdbcSource extends AbstractDataSqlSource { public class DataJdbcSource extends AbstractDataSqlSource {
protected ConnectionPool readPool; protected JdbcConnectionPool readPool;
protected ConnectionPool writePool; protected JdbcConnectionPool writePool;
public DataJdbcSource() { public DataJdbcSource() {
super(); super();
@@ -46,11 +46,11 @@ public class DataJdbcSource extends AbstractDataSqlSource {
@Override @Override
public void init(AnyValue conf) { public void init(AnyValue conf) {
super.init(conf); super.init(conf);
this.readPool = new ConnectionPool(true, readConfProps); this.readPool = new JdbcConnectionPool(true, readConfProps);
if (readConfProps == writeConfProps) { if (readConfProps == writeConfProps) {
this.writePool = readPool; this.writePool = readPool;
} else { } else {
this.writePool = new ConnectionPool(false, writeConfProps); this.writePool = new JdbcConnectionPool(false, writeConfProps);
} }
} }
@@ -113,11 +113,11 @@ public class DataJdbcSource extends AbstractDataSqlSource {
return true; return true;
} }
protected ConnectionPool readPool() { protected JdbcConnectionPool readPool() {
return readPool; return readPool;
} }
protected ConnectionPool writePool() { protected JdbcConnectionPool writePool() {
return writePool; return writePool;
} }
@@ -133,7 +133,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
@Local @Local
public void offerJdbcConnection(DataJdbcConnection conn) { public void offerJdbcConnection(DataJdbcConnection conn) {
ConnectionPool pool = conn.readFlag ? readPool() : writePool(); JdbcConnectionPool pool = conn.readFlag ? readPool() : writePool();
pool.offerConnection(conn); pool.offerConnection(conn);
} }
@@ -2578,7 +2578,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
ResultSet set = stmt.executeQuery(sinfo.getNativeCountSql()); ResultSet set = stmt.executeQuery(sinfo.getNativeCountSql());
if (set.next()) { if (set.next()) {
total = set.getLong(1); total = set.getLong(1);
}; }
set.close(); set.close();
conn.offerQueryStatement(stmt); conn.offerQueryStatement(stmt);
} else { } else {
@@ -2591,7 +2591,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
ResultSet set = prestmt.executeQuery(); ResultSet set = prestmt.executeQuery();
if (set.next()) { if (set.next()) {
total = set.getLong(1); total = set.getLong(1);
}; }
set.close(); set.close();
conn.offerQueryStatement(prestmt); conn.offerQueryStatement(prestmt);
} }
@@ -2838,7 +2838,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
} }
protected class ConnectionPool implements AutoCloseable { protected class JdbcConnectionPool implements AutoCloseable {
protected final LongAdder closeCounter = new LongAdder(); //已关闭连接数 protected final LongAdder closeCounter = new LongAdder(); //已关闭连接数
@@ -2866,7 +2866,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
protected final boolean readFlag; protected final boolean readFlag;
public ConnectionPool(boolean readFlag, Properties prop) { public JdbcConnectionPool(boolean readFlag, Properties prop) {
this.readFlag = readFlag; this.readFlag = readFlag;
this.connectTimeoutSeconds = Integer.decode(prop.getProperty(DATA_SOURCE_CONNECT_TIMEOUT_SECONDS, "30")); this.connectTimeoutSeconds = Integer.decode(prop.getProperty(DATA_SOURCE_CONNECT_TIMEOUT_SECONDS, "30"));
int defMaxConns = Utility.cpus() * 4; int defMaxConns = Utility.cpus() * 4;