Commit c0ba9f1a authored by Quxl's avatar Quxl

x

parent fe127bd3
...@@ -34,6 +34,7 @@ public class SqlTestController { ...@@ -34,6 +34,7 @@ public class SqlTestController {
@PostMapping("executeSql") @PostMapping("executeSql")
public Rjx doExecute(String jdbcUrl, String username, String password, String sql, String parameters) { public Rjx doExecute(String jdbcUrl, String username, String password, String sql, String parameters) {
int queryTimeout = 60;
logger.debug(sql + " " + parameters); logger.debug(sql + " " + parameters);
DruidDataSource dataSource = new DruidDataSource(); DruidDataSource dataSource = new DruidDataSource();
new Thread() { new Thread() {
...@@ -73,12 +74,12 @@ public class SqlTestController { ...@@ -73,12 +74,12 @@ public class SqlTestController {
dataSource.setTestOnReturn(false); dataSource.setTestOnReturn(false);
dataSource.setPoolPreparedStatements(true); dataSource.setPoolPreparedStatements(true);
dataSource.setMaxPoolPreparedStatementPerConnectionSize(20); dataSource.setMaxPoolPreparedStatementPerConnectionSize(20);
dataSource.setQueryTimeout(60); dataSource.setQueryTimeout(queryTimeout);
dataSource.init(); dataSource.init();
JdbcTemplate jdbcTemplate = new JdbcTemplate(); JdbcTemplate jdbcTemplate = new JdbcTemplate();
jdbcTemplate.setDataSource(dataSource); jdbcTemplate.setDataSource(dataSource);
jdbcTemplate.setQueryTimeout(60); jdbcTemplate.setQueryTimeout(queryTimeout);
List<Object> argList = new ArrayList<Object>(); List<Object> argList = new ArrayList<Object>();
if(StringUtil.isNotBlank(parameters)) { if(StringUtil.isNotBlank(parameters)) {
...@@ -102,6 +103,7 @@ public class SqlTestController { ...@@ -102,6 +103,7 @@ public class SqlTestController {
List<?> list = jdbcTemplate.execute(new CallableStatementCreator() { List<?> list = jdbcTemplate.execute(new CallableStatementCreator() {
public CallableStatement createCallableStatement(final Connection con) throws SQLException { public CallableStatement createCallableStatement(final Connection con) throws SQLException {
final CallableStatement cs = con.prepareCall(sql); final CallableStatement cs = con.prepareCall(sql);
cs.setQueryTimeout(queryTimeout);
if(args.length >0) { if(args.length >0) {
for(int i = 0; i < args.length; i++) { for(int i = 0; i < args.length; i++) {
cs.setObject(i+1, args[i]); cs.setObject(i+1, args[i]);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment