kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

提取公共代码 (#3566)

This commit is contained in:
aderm 2019-10-07 16:49:13 +08:00 committed by 吴晟 Wu Sheng
parent e3ecf51eba
commit 7d3b285b6b
1 changed files with 23 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
oap-server/server-library/library-client/src/main/java/org/apache/skywalking/oap/server/library/client/jdbc/hikaricp/JDBCHikariCPClient.java
View File

@ -86,22 +86,7 @@ public class JDBCHikariCPClient implements Client {
PreparedStatement statement = null;
try {
statement = connection.prepareStatement(sql);
if (params != null) {
for (int i = 0; i < params.length; i++) {
Object param = params[i];
if (param instanceof String) {
statement.setString(i + 1, (String)param);
} else if (param instanceof Integer) {
statement.setInt(i + 1, (int)param);
} else if (param instanceof Double) {
statement.setDouble(i + 1, (double)param);
} else if (param instanceof Long) {
statement.setLong(i + 1, (long)param);
} else {
throw new JDBCClientException("Unsupported data type, type=" + param.getClass().getName());
}
}
}
setStatementParam(statement, params);
result = statement.execute();
statement.closeOnCompletion();
} catch (SQLException e) {
@ -123,22 +108,7 @@ public class JDBCHikariCPClient implements Client {
PreparedStatement statement = null;
try {
statement = connection.prepareStatement(sql);
if (params != null) {
for (int i = 0; i < params.length; i++) {
Object param = params[i];
if (param instanceof String) {
statement.setString(i + 1, (String)param);
} else if (param instanceof Integer) {
statement.setInt(i + 1, (int)param);
} else if (param instanceof Double) {
statement.setDouble(i + 1, (double)param);
} else if (param instanceof Long) {
statement.setLong(i + 1, (long)param);
} else {
throw new JDBCClientException("Unsupported data type, type=" + param.getClass().getName());
}
}
}
setStatementParam(statement, params);
rs = statement.executeQuery();
statement.closeOnCompletion();
} catch (SQLException e) {
@ -153,4 +123,25 @@ public class JDBCHikariCPClient implements Client {
return rs;
}
private void setStatementParam(PreparedStatement statement, Object[] params)
throws SQLException, JDBCClientException {
if (params != null) {
for (int i = 0; i < params.length; i++) {
Object param = params[i];
if (param instanceof String) {
statement.setString(i + 1, (String) param);
} else if (param instanceof Integer) {
statement.setInt(i + 1, (int) param);
} else if (param instanceof Double) {
statement.setDouble(i + 1, (double) param);
} else if (param instanceof Long) {
statement.setLong(i + 1, (long) param);
} else {
throw new JDBCClientException(
"Unsupported data type, type=" + param.getClass().getName());
}
}
}
}
}