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

removed unused code.

Browse Source
This commit is contained in:
wenshao
2017-07-31 15:45:16 +08:00
parent f2143e1f26
commit f505f76b5c
1 changed files with 0 additions and 78 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/test/java/com/alibaba/druid/bvt/ApacheDBUtilsTest.java
-78
View File
@@ -1,78 +0,0 @@
package com.alibaba.druid.bvt;
import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.util.JdbcUtils;
import junit.framework.TestCase;
import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.MapHandler;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
/**
* Created by wenshao on 06/07/2017.
*/
public class ApacheDBUtilsTest extends TestCase {
private DruidDataSource dataSource;
protected void setUp() throws Exception {
dataSource = new DruidDataSource();
dataSource.setUrl("jdbc:mysql://rm-bp1n325y4m6h78xt3.mysql.rds.aliyuncs.com:3306/oracle_info?allowMultiQueries=true&characterEncoding=UTF8");
dataSource.setUsername("user1");
dataSource.setPassword("ADAM2d3fb107bcda629fc");
// druid.url=jdbc:mysql://rm-bp1n325y4m6h78xt3.mysql.rds.aliyuncs.com:3306/oracle_info?allowMultiQueries=true&characterEncoding=UTF8
// druid.username=user1
// druid.password=ADAM2d3fb107bcda629fc
}
public void test_txn() throws Exception {
Connection conn = dataSource.getConnection();
Connection conn3 = dataSource.getConnection();
System.out.println("1:" + conn);
QueryRunner runner = new QueryRunner();
String sql = "select task_ida from worker limit 1";
try {
runner.query(conn, sql, new MapHandler());
//Long count = new PgCopy().pipeline(conn, sql, conn3, "worker_0607", "task_id");
} catch (Exception e) {
e.printStackTrace();
//DbUtils.closeQuietly(conn);//直接关闭close
DbUtils.rollbackAndCloseQuietly(conn);
DbUtils.commitAndCloseQuietly(conn);
}
//会抛sql.SQLException: ERROR: current transaction is aborted, commands ignored until end of transaction block Query:
try {
Connection conn1 = dataSource.getConnection();
// conn1.setAutoCommit(true);
System.out.println("2:" + conn1);
String sql1 = "select * from worker limit 1";
QueryRunner runner1 = new QueryRunner();
runner1.query(conn1, sql1, new MapHandler());
} catch (Exception e) {
e.printStackTrace();
}
//恢复正常
try {
Connection conn1 = dataSource.getConnection();
System.out.println("3:" + conn1);
String sql1 = "select * from worker limit 2";
QueryRunner runner1 = new QueryRunner();
runner1.query(conn1, sql1, new MapHandler());
} catch (Exception e) {
e.printStackTrace();
}
}
protected void tearDown() throws Exception {
JdbcUtils.close(dataSource);
}
}