代码格式化

git-svn-id: http://code.alibabatech.com/svn/druid/trunk@76 b9813039-fb51-4c41-a8b9-e21c2acb5095
This commit is contained in:
wenshao
2011-05-14 09:49:00 +00:00
parent aad6bad813
commit 3e3d52f080
68 changed files with 1697 additions and 2929 deletions
@@ -40,8 +40,7 @@ public class TestReplaceLicense extends TestCase {
reader.close();
System.out.println(license);
lineSeparator = (String) java.security.AccessController.doPrivileged(new sun.security.action.GetPropertyAction(
"line.separator"));
lineSeparator = (String) java.security.AccessController.doPrivileged(new sun.security.action.GetPropertyAction("line.separator"));
}
public void test_0() throws Exception {
@@ -98,8 +98,8 @@ public class BenchmarkExecutor {
}
NumberFormat format = NumberFormat.getInstance();
System.out.println("SUM\t" + benchmarkCase.getName() + "\t" + sqlExec.getName() + "\t" + format.format(millis)
+ "\tYoungGC " + youngGC + "\tFullGC " + fullGC);
System.out.println("SUM\t" + benchmarkCase.getName() + "\t" + sqlExec.getName() + "\t" + format.format(millis) + "\tYoungGC " + youngGC + "\tFullGC "
+ fullGC);
}
public void handleResult(SQLExecutor sqlExec, Result result) {
@@ -108,8 +108,8 @@ public class BenchmarkExecutor {
return;
}
NumberFormat format = NumberFormat.getInstance();
System.out.println(result.getName() + "\t" + sqlExec.getName() + "\t" + format.format(result.getMillis())
+ "\tYoungGC " + result.getYoungGC() + "\tFullGC " + result.getFullGC());
System.out.println(result.getName() + "\t" + sqlExec.getName() + "\t" + format.format(result.getMillis()) + "\tYoungGC " + result.getYoungGC()
+ "\tFullGC " + result.getFullGC());
}
private Result executeLoop(SQLExecutor sqlExec, BenchmarkCase benchmarkCase) {
@@ -39,8 +39,7 @@ public class SelectEmptyTable extends BenchmarkCase {
tableName = "T_" + System.currentTimeMillis();
createTableSql = "CREATE TABLE " + tableName
+ "(F1 INT, F2 INT, F3 INT, F4 INT, F5 INT, F6 INT, F7 INT, F8 INT, F9 INT)";
createTableSql = "CREATE TABLE " + tableName + "(F1 INT, F2 INT, F3 INT, F4 INT, F5 INT, F6 INT, F7 INT, F8 INT, F9 INT)";
dropTableSql = "DROP TABLE " + tableName;
sql = "SELECT * FROM T_" + tableName;
}
@@ -11,42 +11,43 @@ import junit.framework.TestCase;
import org.junit.Assert;
public class MockExecuteTest extends TestCase {
public void test_0 () throws Exception {
public void test_0() throws Exception {
Connection conn = DriverManager.getConnection("jdbc:mock:");
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SELECT 2");
Assert.assertTrue(rs.next());
Assert.assertEquals(2, rs.getInt(1));
rs.close();
stmt.close();
conn.close();
}
public void test_1 () throws Exception {
public void test_1() throws Exception {
Connection conn = DriverManager.getConnection("jdbc:mock:");
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SELECT NULL");
Assert.assertTrue(rs.next());
Assert.assertEquals(0, rs.getInt(1));
Assert.assertEquals(null, rs.getObject(1));
rs.close();
stmt.close();
conn.close();
}
public void test_2 () throws Exception {
public void test_2() throws Exception {
Connection conn = DriverManager.getConnection("jdbc:mock:");
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SELECT NOW()");
Assert.assertTrue(rs.next());
Assert.assertTrue(rs.getObject(1) instanceof Timestamp);
rs.close();
stmt.close();
conn.close();
}
@@ -9,6 +9,7 @@ import org.junit.Assert;
import com.alibaba.druid.mock.MockResultSetMetaData;
public class MockResultSetMetaDataTest extends TestCase {
public void test_resultSet_metadata() throws Exception {
MockResultSetMetaData meta = new MockResultSetMetaData();
Assert.assertTrue(meta.isWrapperFor(MockResultSetMetaData.class));
@@ -56,10 +56,10 @@ public class DruidDataSourceFilterTest extends TestCase {
Assert.assertEquals(0, JdbcStatManager.getInstance().getConnectionstat().getCloseCount()); // logic
// close不会导致计数器+1
}
dataSource.close();
Assert.assertEquals(1, JdbcStatManager.getInstance().getConnectionstat().getConnectCount());
Assert.assertEquals(1, JdbcStatManager.getInstance().getConnectionstat().getCloseCount());
Assert.assertEquals(1, JdbcStatManager.getInstance().getConnectionstat().getCloseCount());
}
}
@@ -18,26 +18,28 @@ import com.alibaba.druid.filter.FilterChain;
import com.alibaba.druid.proxy.jdbc.ConnectionProxy;
public class SpringFilterTest extends TestCase {
public void test_spring() throws Exception {
ApplicationContext context = new ClassPathXmlApplicationContext("com/alibaba/druid/pool/spring-config-1.xml");
DataSource dataSource = (DataSource) context.getBean("dataSource");
Connection conn = dataSource.getConnection();
conn.close();
TestFilter filter = (TestFilter) context.getBean("test-filter");
Assert.assertEquals(1, filter.getConnectCount());
}
public static class TestFilter extends FilterAdapter {
private AtomicLong connectCount = new AtomicLong();
@Override
public ConnectionProxy connection_connect(FilterChain chain, Properties info) throws SQLException {
connectCount.incrementAndGet();
return chain.connection_connect(info);
}
public long getConnectCount() {
return connectCount.get();
}
@@ -53,9 +53,7 @@ public class BasicTypeTest extends TestCase {
Statement stmt = conn.createStatement();
stmt.execute("CREATE TABLE T_BASIC_TYPE (F1 FLOAT, F2 DOUBLE, F3 REAL, F4 DATE, F5 TIME, F6 SMALLINT, F7 SMALLINT, F8 INTEGER, F9 BIGINT, F10 DECIMAL(9,2), F11 TIMESTAMP, F12 BLOB, F13 VARCHAR(256), F14 VARCHAR(256), F15 VARCHAR(256), F16 VARCHAR(256), F17 SMALLINT)");
stmt.execute("CREATE PROCEDURE BASIC_CALL_0(INOUT F1 FLOAT, INOUT F2 DOUBLE, INOUT F3 REAL, INOUT F4 DATE, INOUT F5 TIME, INOUT F6 SMALLINT, INOUT F7 SMALLINT, INOUT F8 INTEGER, INOUT F9 BIGINT, INOUT F10 DECIMAL(9,2), INOUT F11 TIMESTAMP, INOUT F12 VARCHAR(128) FOR BIT DATA, INOUT F13 VARCHAR(256), INOUT F14 VARCHAR(256), INOUT F15 VARCHAR(256), INOUT F16 VARCHAR(256), INOUT F17 SMALLINT) "
+ "LANGUAGE JAVA PARAMETER STYLE JAVA EXTERNAL NAME '"
+ BasicTypeTest.class.getName()
+ ".basic_process_0' " + "DYNAMIC RESULT SETS 1");
+ "LANGUAGE JAVA PARAMETER STYLE JAVA EXTERNAL NAME '" + BasicTypeTest.class.getName() + ".basic_process_0' " + "DYNAMIC RESULT SETS 1");
stmt.close();
conn.close();
}
@@ -125,8 +123,7 @@ public class BasicTypeTest extends TestCase {
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE);
stmt.close();
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE,
ResultSet.CLOSE_CURSORS_AT_COMMIT);
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE, ResultSet.CLOSE_CURSORS_AT_COMMIT);
stmt.setQueryTimeout(stmt.getQueryTimeout());
stmt.setEscapeProcessing(true);
stmt.clearBatch();
@@ -252,12 +249,11 @@ public class BasicTypeTest extends TestCase {
pstmt = conn.prepareStatement("SELECT F1, F2, F3, F4, F5, F6, F7, F8, F9, F10, F11, F12, F13, F14, F15, F16 FROM T_BASIC_TYPE");
JdbcUtils.close(pstmt);
pstmt = conn.prepareStatement("SELECT F1, F2, F3, F4, F5, F6, F7, F8, F9, F10, F11, F12, F13, F14, F15, F16 FROM T_BASIC_TYPE",
new int[] { 1, 2 });
pstmt = conn.prepareStatement("SELECT F1, F2, F3, F4, F5, F6, F7, F8, F9, F10, F11, F12, F13, F14, F15, F16 FROM T_BASIC_TYPE", new int[] { 1, 2 });
JdbcUtils.close(pstmt);
pstmt = conn.prepareStatement("SELECT F1, F2, F3, F4, F5, F6, F7, F8, F9, F10, F11, F12, F13, F14, F15, F16 FROM T_BASIC_TYPE",
new String[] { "F1", "F2" });
pstmt = conn.prepareStatement("SELECT F1, F2, F3, F4, F5, F6, F7, F8, F9, F10, F11, F12, F13, F14, F15, F16 FROM T_BASIC_TYPE", new String[] {
"F1", "F2" });
JdbcUtils.close(pstmt);
pstmt = conn.prepareStatement("SELECT F1, F2, F3, F4, F5, F6, F7, F8, F9, F10, F11, F12, F13, F14, F15, F16 FROM T_BASIC_TYPE",
@@ -270,8 +266,7 @@ public class BasicTypeTest extends TestCase {
JdbcUtils.close(pstmt);
pstmt = conn.prepareStatement("SELECT F1, F2, F3, F4, F5, F6, F7, F8, F9, F10, F11, F12, F13, F14, F15, F16 FROM T_BASIC_TYPE",
ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE,
ResultSet.CLOSE_CURSORS_AT_COMMIT);
ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE, ResultSet.CLOSE_CURSORS_AT_COMMIT);
JdbcUtils.close(pstmt);
cstmt = conn.prepareCall("CALL BASIC_CALL_0(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?,?, ?, ?, ?)");
@@ -691,10 +686,9 @@ public class BasicTypeTest extends TestCase {
}
}
public static void basic_process_0(double[] p1, double[] p2, float[] p3, java.sql.Date[] p4, java.sql.Time[] p5,
short[] p6, short[] p7, int[] p8, long[] p9, BigDecimal[] p10,
java.sql.Timestamp[] p11, byte[][] p12, String[] p13, String[] p14,
String[] p15, String[] p16, short[] P17, ResultSet[] p18) {
public static void basic_process_0(double[] p1, double[] p2, float[] p3, java.sql.Date[] p4, java.sql.Time[] p5, short[] p6, short[] p7, int[] p8,
long[] p9, BigDecimal[] p10, java.sql.Timestamp[] p11, byte[][] p12, String[] p13, String[] p14, String[] p15,
String[] p16, short[] P17, ResultSet[] p18) {
// stmt.execute("CREATE TABLE T_BASIC_TYPE (F1 FLOAT, F2 DOUBLE, F3
// REAL, F4 DATE,
// F5 TIME, F6 SMALLINT, F7 SMALLINT, F8 INTEGER, F9 BIGINT, F10
@@ -102,8 +102,7 @@ public class BlobTest extends TestCase {
updateCount = pstmt.executeUpdate();
Assert.assertEquals(1, updateCount);
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE,
ResultSet.CLOSE_CURSORS_AT_COMMIT);
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE, ResultSet.CLOSE_CURSORS_AT_COMMIT);
conn.nativeSQL("SELECT ID, DATA FROM T_BLOB");
// //////
@@ -34,24 +34,20 @@ public class CallStatementTest extends TestCase {
*/
private static final String[] PROCEDURES = {
"CREATE PROCEDURE RETRIEVE_DYNAMIC_RESULTS(number INT) "
+ "LANGUAGE JAVA PARAMETER STYLE JAVA EXTERNAL NAME '" + CallStatementTest.class.getName()
"CREATE PROCEDURE RETRIEVE_DYNAMIC_RESULTS(number INT) " + "LANGUAGE JAVA PARAMETER STYLE JAVA EXTERNAL NAME '" + CallStatementTest.class.getName()
+ ".retrieveDynamicResults' " + "DYNAMIC RESULT SETS 4",
"CREATE PROCEDURE RETRIEVE_CLOSED_RESULT() LANGUAGE JAVA " + "PARAMETER STYLE JAVA EXTERNAL NAME '"
+ CallStatementTest.class.getName() + ".retrieveClosedResult' " + "DYNAMIC RESULT SETS 1",
"CREATE PROCEDURE RETRIEVE_CLOSED_RESULT() LANGUAGE JAVA " + "PARAMETER STYLE JAVA EXTERNAL NAME '" + CallStatementTest.class.getName()
+ ".retrieveClosedResult' " + "DYNAMIC RESULT SETS 1",
"CREATE PROCEDURE RETRIEVE_EXTERNAL_RESULT("
+ "DBNAME VARCHAR(128), DBUSER VARCHAR(128), DBPWD VARCHAR(128)) LANGUAGE JAVA "
+ "PARAMETER STYLE JAVA EXTERNAL NAME '" + CallStatementTest.class.getName()
+ ".retrieveExternalResult' " + "DYNAMIC RESULT SETS 1",
"CREATE PROCEDURE RETRIEVE_EXTERNAL_RESULT(" + "DBNAME VARCHAR(128), DBUSER VARCHAR(128), DBPWD VARCHAR(128)) LANGUAGE JAVA "
+ "PARAMETER STYLE JAVA EXTERNAL NAME '" + CallStatementTest.class.getName() + ".retrieveExternalResult' " + "DYNAMIC RESULT SETS 1",
"CREATE PROCEDURE PROC_WITH_SIDE_EFFECTS(ret INT) LANGUAGE JAVA " + "PARAMETER STYLE JAVA EXTERNAL NAME '"
+ CallStatementTest.class.getName() + ".procWithSideEffects' " + "DYNAMIC RESULT SETS 2",
"CREATE PROCEDURE PROC_WITH_SIDE_EFFECTS(ret INT) LANGUAGE JAVA " + "PARAMETER STYLE JAVA EXTERNAL NAME '" + CallStatementTest.class.getName()
+ ".procWithSideEffects' " + "DYNAMIC RESULT SETS 2",
"CREATE PROCEDURE NESTED_RESULT_SETS(proctext VARCHAR(128)) LANGUAGE JAVA "
+ "PARAMETER STYLE JAVA EXTERNAL NAME '" + CallStatementTest.class.getName()
+ ".nestedDynamicResultSets' " + "DYNAMIC RESULT SETS 6"
"CREATE PROCEDURE NESTED_RESULT_SETS(proctext VARCHAR(128)) LANGUAGE JAVA " + "PARAMETER STYLE JAVA EXTERNAL NAME '"
+ CallStatementTest.class.getName() + ".nestedDynamicResultSets' " + "DYNAMIC RESULT SETS 6"
};
@@ -135,8 +131,7 @@ public class CallStatementTest extends TestCase {
connect.close();
}
public static void retrieveExternalResult(String dbName, String user, String password, ResultSet[] external)
throws SQLException {
public static void retrieveExternalResult(String dbName, String user, String password, ResultSet[] external) throws SQLException {
Connection conn = DriverManager.getConnection(create_url);
@@ -195,8 +190,7 @@ public class CallStatementTest extends TestCase {
conn.close();
}
public static void fivejp(ResultSet[] data1, ResultSet[] data2, ResultSet[] data3, ResultSet[] data4,
ResultSet[] data5) throws SQLException {
public static void fivejp(ResultSet[] data1, ResultSet[] data2, ResultSet[] data3, ResultSet[] data4, ResultSet[] data5) throws SQLException {
Connection conn = DriverManager.getConnection("jdbc:default:connection");
@@ -246,8 +240,7 @@ public class CallStatementTest extends TestCase {
conn.close();
}
public static void parameter2(int a, java.math.BigDecimal b, java.math.BigDecimal c, java.sql.ResultSet[] rs)
throws SQLException {
public static void parameter2(int a, java.math.BigDecimal b, java.math.BigDecimal c, java.sql.ResultSet[] rs) throws SQLException {
Connection conn = DriverManager.getConnection("jdbc:default:connection");
PreparedStatement ps = conn.prepareStatement("insert into PT1 values (?, ?, ?)");
ps.setInt(1, a);
@@ -261,8 +254,7 @@ public class CallStatementTest extends TestCase {
conn.close();
}
public static void retrieveDynamicResults(int number, ResultSet[] rs1, ResultSet[] rs2, ResultSet[] rs3,
ResultSet[] rs4) throws SQLException {
public static void retrieveDynamicResults(int number, ResultSet[] rs1, ResultSet[] rs2, ResultSet[] rs3, ResultSet[] rs4) throws SQLException {
Connection c = DriverManager.getConnection("jdbc:default:connection");
if (number > 0) {
rs1[0] = c.createStatement().executeQuery("VALUES(1)");
@@ -102,8 +102,7 @@ public class ClobTest extends TestCase {
updateCount = pstmt.executeUpdate();
Assert.assertEquals(1, updateCount);
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE,
ResultSet.CLOSE_CURSORS_AT_COMMIT);
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE, ResultSet.CLOSE_CURSORS_AT_COMMIT);
// //////
rs = stmt.executeQuery("SELECT ID, DATA FROM T_CLOB");
@@ -85,8 +85,7 @@ public class DruidDriverTest extends TestCase {
public void test_getRawDriverClassName() throws Exception {
Assert.assertEquals("com.mysql.jdbc.Driver", JdbcUtils.getDriverClassName("jdbc:mysql:"));
Assert.assertEquals("oracle.jdbc.driver.OracleDriver", JdbcUtils.getDriverClassName("jdbc:oracle:"));
Assert.assertEquals("com.microsoft.jdbc.sqlserver.SQLServerDriver",
JdbcUtils.getDriverClassName("jdbc:microsoft:"));
Assert.assertEquals("com.microsoft.jdbc.sqlserver.SQLServerDriver", JdbcUtils.getDriverClassName("jdbc:microsoft:"));
Assert.assertEquals("org.postgresql.Driver", JdbcUtils.getDriverClassName("jdbc:postgresql:xx"));
Assert.assertEquals("net.sourceforge.jtds.jdbc.Driver", JdbcUtils.getDriverClassName("jdbc:jtds:"));
{
@@ -186,8 +185,7 @@ public class DruidDriverTest extends TestCase {
Exception error = null;
try {
driver.connect("jdbc:wrap-jdbc:filters=" + PrivateJdbcFilterAdapter.class.getName()
+ ":name=driverWrapperTest:jdbc:derby:memory:driverWrapperTestDB;create=true",
new Properties()).close();
+ ":name=driverWrapperTest:jdbc:derby:memory:driverWrapperTestDB;create=true", new Properties()).close();
} catch (Exception ex) {
error = ex;
}
@@ -197,8 +195,7 @@ public class DruidDriverTest extends TestCase {
Exception error = null;
try {
driver.connect("jdbc:wrap-jdbc:filters=" + InitErrorJdbcFilterAdapter.class.getName()
+ ":name=driverWrapperTest:jdbc:derby:memory:driverWrapperTestDB;create=true",
new Properties()).close();
+ ":name=driverWrapperTest:jdbc:derby:memory:driverWrapperTestDB;create=true", new Properties()).close();
} catch (Exception ex) {
error = ex;
}
@@ -105,8 +105,7 @@ public class JdbcFilterEventAdapterTest extends TestCase {
{
FilterChain chain = new FilterChainImpl(new DataSourceProxyImpl(null, config)) {
public boolean statement_execute(StatementProxy statement, String sql, int autoGeneratedKeys)
throws SQLException {
public boolean statement_execute(StatementProxy statement, String sql, int autoGeneratedKeys) throws SQLException {
throw new SQLException();
}
};
@@ -123,8 +122,7 @@ public class JdbcFilterEventAdapterTest extends TestCase {
{
FilterChain chain = new FilterChainImpl(new DataSourceProxyImpl(null, config)) {
public boolean statement_execute(StatementProxy statement, String sql, int autoGeneratedKeys)
throws SQLException {
public boolean statement_execute(StatementProxy statement, String sql, int autoGeneratedKeys) throws SQLException {
throw new RuntimeException();
}
};
@@ -141,8 +139,7 @@ public class JdbcFilterEventAdapterTest extends TestCase {
{
FilterChain chain = new FilterChainImpl(new DataSourceProxyImpl(null, config)) {
public boolean statement_execute(StatementProxy statement, String sql, int autoGeneratedKeys)
throws SQLException {
public boolean statement_execute(StatementProxy statement, String sql, int autoGeneratedKeys) throws SQLException {
throw new Error();
}
};
@@ -161,8 +158,7 @@ public class JdbcFilterEventAdapterTest extends TestCase {
{
FilterChain chain = new FilterChainImpl(new DataSourceProxyImpl(null, config)) {
public boolean statement_execute(StatementProxy statement, String sql, int columnIndexes[])
throws SQLException {
public boolean statement_execute(StatementProxy statement, String sql, int columnIndexes[]) throws SQLException {
throw new SQLException();
}
};
@@ -179,8 +175,7 @@ public class JdbcFilterEventAdapterTest extends TestCase {
{
FilterChain chain = new FilterChainImpl(new DataSourceProxyImpl(null, config)) {
public boolean statement_execute(StatementProxy statement, String sql, int columnIndexes[])
throws SQLException {
public boolean statement_execute(StatementProxy statement, String sql, int columnIndexes[]) throws SQLException {
throw new RuntimeException();
}
};
@@ -197,8 +192,7 @@ public class JdbcFilterEventAdapterTest extends TestCase {
{
FilterChain chain = new FilterChainImpl(new DataSourceProxyImpl(null, config)) {
public boolean statement_execute(StatementProxy statement, String sql, int columnIndexes[])
throws SQLException {
public boolean statement_execute(StatementProxy statement, String sql, int columnIndexes[]) throws SQLException {
throw new Error();
}
};
@@ -217,8 +211,7 @@ public class JdbcFilterEventAdapterTest extends TestCase {
{
FilterChain chain = new FilterChainImpl(new DataSourceProxyImpl(null, config)) {
public boolean statement_execute(StatementProxy statement, String sql, String columnNames[])
throws SQLException {
public boolean statement_execute(StatementProxy statement, String sql, String columnNames[]) throws SQLException {
throw new SQLException();
}
};
@@ -235,8 +228,7 @@ public class JdbcFilterEventAdapterTest extends TestCase {
{
FilterChain chain = new FilterChainImpl(new DataSourceProxyImpl(null, config)) {
public boolean statement_execute(StatementProxy statement, String sql, String columnNames[])
throws SQLException {
public boolean statement_execute(StatementProxy statement, String sql, String columnNames[]) throws SQLException {
throw new RuntimeException();
}
};
@@ -253,8 +245,7 @@ public class JdbcFilterEventAdapterTest extends TestCase {
{
FilterChain chain = new FilterChainImpl(new DataSourceProxyImpl(null, config)) {
public boolean statement_execute(StatementProxy statement, String sql, String columnNames[])
throws SQLException {
public boolean statement_execute(StatementProxy statement, String sql, String columnNames[]) throws SQLException {
throw new Error();
}
};
@@ -487,8 +478,7 @@ public class JdbcFilterEventAdapterTest extends TestCase {
{
FilterChain chain = new FilterChainImpl(new DataSourceProxyImpl(null, config)) {
public int statement_executeUpdate(StatementProxy statement, String sql, int autoGeneratedKeys)
throws SQLException {
public int statement_executeUpdate(StatementProxy statement, String sql, int autoGeneratedKeys) throws SQLException {
throw new SQLException();
}
};
@@ -505,8 +495,7 @@ public class JdbcFilterEventAdapterTest extends TestCase {
{
FilterChain chain = new FilterChainImpl(new DataSourceProxyImpl(null, config)) {
public int statement_executeUpdate(StatementProxy statement, String sql, int autoGeneratedKeys)
throws SQLException {
public int statement_executeUpdate(StatementProxy statement, String sql, int autoGeneratedKeys) throws SQLException {
throw new RuntimeException();
}
};
@@ -523,8 +512,7 @@ public class JdbcFilterEventAdapterTest extends TestCase {
{
FilterChain chain = new FilterChainImpl(new DataSourceProxyImpl(null, config)) {
public int statement_executeUpdate(StatementProxy statement, String sql, int autoGeneratedKeys)
throws SQLException {
public int statement_executeUpdate(StatementProxy statement, String sql, int autoGeneratedKeys) throws SQLException {
throw new Error();
}
};
@@ -543,8 +531,7 @@ public class JdbcFilterEventAdapterTest extends TestCase {
{
FilterChain chain = new FilterChainImpl(new DataSourceProxyImpl(null, config)) {
public int statement_executeUpdate(StatementProxy statement, String sql, int columnIndexes[])
throws SQLException {
public int statement_executeUpdate(StatementProxy statement, String sql, int columnIndexes[]) throws SQLException {
throw new SQLException();
}
};
@@ -561,8 +548,7 @@ public class JdbcFilterEventAdapterTest extends TestCase {
{
FilterChain chain = new FilterChainImpl(new DataSourceProxyImpl(null, config)) {
public int statement_executeUpdate(StatementProxy statement, String sql, int columnIndexes[])
throws SQLException {
public int statement_executeUpdate(StatementProxy statement, String sql, int columnIndexes[]) throws SQLException {
throw new RuntimeException();
}
};
@@ -579,8 +565,7 @@ public class JdbcFilterEventAdapterTest extends TestCase {
{
FilterChain chain = new FilterChainImpl(new DataSourceProxyImpl(null, config)) {
public int statement_executeUpdate(StatementProxy statement, String sql, int columnIndexes[])
throws SQLException {
public int statement_executeUpdate(StatementProxy statement, String sql, int columnIndexes[]) throws SQLException {
throw new Error();
}
};
@@ -599,8 +584,7 @@ public class JdbcFilterEventAdapterTest extends TestCase {
{
FilterChain chain = new FilterChainImpl(new DataSourceProxyImpl(null, config)) {
public int statement_executeUpdate(StatementProxy statement, String sql, String columnNames[])
throws SQLException {
public int statement_executeUpdate(StatementProxy statement, String sql, String columnNames[]) throws SQLException {
throw new SQLException();
}
};
@@ -617,8 +601,7 @@ public class JdbcFilterEventAdapterTest extends TestCase {
{
FilterChain chain = new FilterChainImpl(new DataSourceProxyImpl(null, config)) {
public int statement_executeUpdate(StatementProxy statement, String sql, String columnNames[])
throws SQLException {
public int statement_executeUpdate(StatementProxy statement, String sql, String columnNames[]) throws SQLException {
throw new RuntimeException();
}
};
@@ -635,8 +618,7 @@ public class JdbcFilterEventAdapterTest extends TestCase {
{
FilterChain chain = new FilterChainImpl(new DataSourceProxyImpl(null, config)) {
public int statement_executeUpdate(StatementProxy statement, String sql, String columnNames[])
throws SQLException {
public int statement_executeUpdate(StatementProxy statement, String sql, String columnNames[]) throws SQLException {
throw new Error();
}
};
@@ -733,8 +715,7 @@ public class JdbcFilterEventAdapterTest extends TestCase {
{
FilterChain chain = new FilterChainImpl(new DataSourceProxyImpl(null, config)) {
public ResultSetProxy preparedStatement_executeQuery(PreparedStatementProxy statement)
throws SQLException {
public ResultSetProxy preparedStatement_executeQuery(PreparedStatementProxy statement) throws SQLException {
throw new SQLException();
}
};
@@ -751,8 +732,7 @@ public class JdbcFilterEventAdapterTest extends TestCase {
{
FilterChain chain = new FilterChainImpl(new DataSourceProxyImpl(null, config)) {
public ResultSetProxy preparedStatement_executeQuery(PreparedStatementProxy statement)
throws SQLException {
public ResultSetProxy preparedStatement_executeQuery(PreparedStatementProxy statement) throws SQLException {
throw new RuntimeException();
}
};
@@ -769,8 +749,7 @@ public class JdbcFilterEventAdapterTest extends TestCase {
{
FilterChain chain = new FilterChainImpl(new DataSourceProxyImpl(null, config)) {
public ResultSetProxy preparedStatement_executeQuery(PreparedStatementProxy statement)
throws SQLException {
public ResultSetProxy preparedStatement_executeQuery(PreparedStatementProxy statement) throws SQLException {
throw new Error();
}
};
@@ -77,12 +77,11 @@ public class PrecallTest extends TestCase {
try {
conn = DriverManager.getConnection(create_url);
cstmt = conn.prepareCall("CALL SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY(?, ?)", ResultSet.FETCH_FORWARD,
ResultSet.CONCUR_READ_ONLY);
cstmt = conn.prepareCall("CALL SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY(?, ?)", ResultSet.FETCH_FORWARD, ResultSet.CONCUR_READ_ONLY);
cstmt.close();
cstmt = conn.prepareCall("CALL SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY(?, ?)", ResultSet.FETCH_FORWARD,
ResultSet.CONCUR_READ_ONLY, ResultSet.CLOSE_CURSORS_AT_COMMIT);
cstmt = conn.prepareCall("CALL SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY(?, ?)", ResultSet.FETCH_FORWARD, ResultSet.CONCUR_READ_ONLY,
ResultSet.CLOSE_CURSORS_AT_COMMIT);
cstmt.close();
cstmt = conn.prepareCall("CALL SYSCS_UTIL.SYSCS_SET_DATABASE_PROPERTY(?, ?)");
@@ -77,8 +77,7 @@ public class PreparedStatementTest extends TestCase {
try {
conn = DriverManager.getConnection(create_url);
pstmt = conn.prepareStatement("INSERT INTO T_PRE_STMT_TEST (ID, NAME, BIRTHDATE) VALUES (?, ?, ?)",
Statement.RETURN_GENERATED_KEYS);
pstmt = conn.prepareStatement("INSERT INTO T_PRE_STMT_TEST (ID, NAME, BIRTHDATE) VALUES (?, ?, ?)", Statement.RETURN_GENERATED_KEYS);
pstmt.setShort(1, (short) 1);
pstmt.setString(2, "A");
@@ -165,8 +164,7 @@ public class PreparedStatementTest extends TestCase {
}
pstmt.execute();
pstmt2 = conn.prepareStatement("SELECT * FROM T_PRE_STMT_TEST ORDER BY 2", ResultSet.TYPE_SCROLL_SENSITIVE,
ResultSet.CONCUR_UPDATABLE);
pstmt2 = conn.prepareStatement("SELECT * FROM T_PRE_STMT_TEST ORDER BY 2", ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
rs = pstmt2.executeQuery();
rs.getCursorName();
rs.clearWarnings();
@@ -196,15 +194,14 @@ public class PreparedStatementTest extends TestCase {
rs.last();
rs.close();
pstmt2 = conn.prepareStatement("SELECT * FROM T_PRE_STMT_TEST ORDER BY 2", ResultSet.TYPE_SCROLL_SENSITIVE,
ResultSet.CONCUR_UPDATABLE);
pstmt2 = conn.prepareStatement("SELECT * FROM T_PRE_STMT_TEST ORDER BY 2", ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
rs = pstmt2.executeQuery();
rs.first();
rs.last();
rs.close();
pstmt2 = conn.prepareStatement("SELECT * FROM T_PRE_STMT_TEST ORDER BY 2", ResultSet.TYPE_SCROLL_SENSITIVE,
ResultSet.CONCUR_UPDATABLE, ResultSet.CLOSE_CURSORS_AT_COMMIT);
pstmt2 = conn.prepareStatement("SELECT * FROM T_PRE_STMT_TEST ORDER BY 2", ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE,
ResultSet.CLOSE_CURSORS_AT_COMMIT);
rs = pstmt2.executeQuery();
rs.first();
rs.last();
@@ -285,8 +282,7 @@ public class PreparedStatementTest extends TestCase {
JdbcUtils.printResultSet(rs, System.out);
rs.close();
pstmt2 = conn.prepareStatement("SELECT * FROM T_PRE_STMT_TEST ORDER BY 2",
ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE);
pstmt2 = conn.prepareStatement("SELECT * FROM T_PRE_STMT_TEST ORDER BY 2", ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE);
rs = pstmt2.executeQuery();
rs.next();
try {
@@ -72,18 +72,13 @@ public class StatementTest extends TestCase {
stmt = conn.createStatement();
stmt.execute("INSERT INTO T_PRE_STMT_TEST (ID, NAME, BIRTHDATE) VALUES (1, 'A', NULL)");
stmt.execute("INSERT INTO T_PRE_STMT_TEST (ID, NAME, BIRTHDATE) VALUES (11, 'A1', NULL)",
Statement.NO_GENERATED_KEYS);
stmt.execute("INSERT INTO T_PRE_STMT_TEST (ID, NAME, BIRTHDATE) VALUES (11, 'A1', NULL)", Statement.NO_GENERATED_KEYS);
stmt.execute("INSERT INTO T_PRE_STMT_TEST (ID, NAME, BIRTHDATE) VALUES (12, 'A2', NULL)", new int[] { 1 });
stmt.execute("INSERT INTO T_PRE_STMT_TEST (ID, NAME, BIRTHDATE) VALUES (12, 'A3', NULL)",
new String[] { "ID" });
stmt.execute("INSERT INTO T_PRE_STMT_TEST (ID, NAME, BIRTHDATE) VALUES (12, 'A3', NULL)", new String[] { "ID" });
stmt.executeUpdate("INSERT INTO T_PRE_STMT_TEST (ID, NAME, BIRTHDATE) VALUES (2, 'B', NULL)");
stmt.executeUpdate("INSERT INTO T_PRE_STMT_TEST (ID, NAME, BIRTHDATE) VALUES (3, 'C', NULL)",
Statement.NO_GENERATED_KEYS);
stmt.executeUpdate("INSERT INTO T_PRE_STMT_TEST (ID, NAME, BIRTHDATE) VALUES (4, 'D', NULL)",
new int[] { 1 });
stmt.executeUpdate("INSERT INTO T_PRE_STMT_TEST (ID, NAME, BIRTHDATE) VALUES (5, 'E', NULL)",
new String[] { "ID" });
stmt.executeUpdate("INSERT INTO T_PRE_STMT_TEST (ID, NAME, BIRTHDATE) VALUES (3, 'C', NULL)", Statement.NO_GENERATED_KEYS);
stmt.executeUpdate("INSERT INTO T_PRE_STMT_TEST (ID, NAME, BIRTHDATE) VALUES (4, 'D', NULL)", new int[] { 1 });
stmt.executeUpdate("INSERT INTO T_PRE_STMT_TEST (ID, NAME, BIRTHDATE) VALUES (5, 'E', NULL)", new String[] { "ID" });
try {
stmt.cancel();
} catch (SQLFeatureNotSupportedException ex) {
@@ -45,8 +45,7 @@ public class DruidConfigLoaderTest extends TestCase {
Assert.assertEquals("gbk", druidConfig.getClientEncoding());
Assert.assertEquals("utf8", druidConfig.getServerEncoding());
} else if ("stat".equalsIgnoreCase(abstractDruidFilterConfig.getName())) {
Assert.assertEquals("com.alibaba.druid.proxy.filter.stat.StatFilter",
abstractDruidFilterConfig.getClazz());
Assert.assertEquals("com.alibaba.druid.proxy.filter.stat.StatFilter", abstractDruidFilterConfig.getClazz());
}
}
@@ -26,7 +26,7 @@ public class ClobTest extends TestCase {
ResultSet rs = stmt.executeQuery("SELECT NULL");
Assert.assertTrue(rs.next());
{
Clob x = rs.getClob(1);
Assert.assertNull(x);
@@ -79,8 +79,7 @@ public class DruidLoaderUtilsTest extends TestCase {
DruidLoaderUtils.loadFilter(filters, filterItem);
filterConfig = filters.get(0);
Assert.assertNotNull(filterConfig);
Assert.assertEquals("com.alibaba.druid.filter.encoding.EncodingConvertFilter",
filterConfig.getClass().getName());
Assert.assertEquals("com.alibaba.druid.filter.encoding.EncodingConvertFilter", filterConfig.getClass().getName());
// 判定重复
filterItem = "stat";
filters.clear();
@@ -115,10 +114,8 @@ public class DruidLoaderUtilsTest extends TestCase {
Assert.assertEquals(null, DruidLoaderUtils.loadClass2(null));
Assert.assertEquals(null, DruidLoaderUtils.loadClass("xxx"));
Assert.assertEquals(null, DruidLoaderUtils.loadClass2("xxx"));
Assert.assertEquals(PublicJdbcFilterAdapter.class,
DruidLoaderUtils.loadClass(PublicJdbcFilterAdapter.class.getName()));
Assert.assertEquals(PublicJdbcFilterAdapter.class,
DruidLoaderUtils.loadClass2(PublicJdbcFilterAdapter.class.getName()));
Assert.assertEquals(PublicJdbcFilterAdapter.class, DruidLoaderUtils.loadClass(PublicJdbcFilterAdapter.class.getName()));
Assert.assertEquals(PublicJdbcFilterAdapter.class, DruidLoaderUtils.loadClass2(PublicJdbcFilterAdapter.class.getName()));
Assert.assertNull(DruidLoaderUtils.loadClass(null));
Assert.assertNull(DruidLoaderUtils.loadClass(""));
}
@@ -130,7 +130,6 @@ public class Case0 extends TestCase {
long ygc = TestUtil.getYoungGC() - startYGC;
long fullGC = TestUtil.getFullGC() - startFullGC;
System.out.println(name + " millis : " + NumberFormat.getInstance().format(millis) + ", YGC " + ygc + " FGC "
+ fullGC);
System.out.println(name + " millis : " + NumberFormat.getInstance().format(millis) + ", YGC " + ygc + " FGC " + fullGC);
}
}
@@ -152,7 +152,6 @@ public class Case1 extends TestCase {
long ygc = TestUtil.getYoungGC() - startYGC;
long fullGC = TestUtil.getFullGC() - startFullGC;
System.out.println("thread " + threadCount + " " + name + " millis : "
+ NumberFormat.getInstance().format(millis) + ", YGC " + ygc + " FGC " + fullGC);
System.out.println("thread " + threadCount + " " + name + " millis : " + NumberFormat.getInstance().format(millis) + ", YGC " + ygc + " FGC " + fullGC);
}
}
@@ -79,8 +79,7 @@ public class CastFunctionsAndOperatorsTest extends TestCase {
String text = output(stmtList);
Assert.assertEquals("SELECT 'A' LIKE CONVERT(blob_col USING latin1) COLLATE latin1_german1_ci\nFROM tbl_name;",
text);
Assert.assertEquals("SELECT 'A' LIKE CONVERT(blob_col USING latin1) COLLATE latin1_german1_ci\nFROM tbl_name;", text);
}
public void test_5() throws Exception {
@@ -35,8 +35,7 @@ public class DateAndTimeFunctionsTest extends TestCase {
String text = output(stmtList);
Assert.assertEquals("SELECT something\nFROM tbl_name\nWHERE DATE_SUB(CURDATE(), INTERVAL 30 DAY) <= date_col;",
text);
Assert.assertEquals("SELECT something\nFROM tbl_name\nWHERE DATE_SUB(CURDATE(), INTERVAL 30 DAY) <= date_col;", text);
}
public void test_1() throws Exception {
@@ -35,8 +35,7 @@ public class FullTextSearchesWithQueryExpansionTest extends TestCase {
String text = output(stmtList);
Assert.assertEquals("SELECT *\nFROM articles\nWHERE MATCH (title, body) AGAINST ('database' IN NATURAL LANGUAGE MODE);",
text);
Assert.assertEquals("SELECT *\nFROM articles\nWHERE MATCH (title, body) AGAINST ('database' IN NATURAL LANGUAGE MODE);", text);
}
private String output(List<SQLStatement> stmtList) {
@@ -90,8 +90,7 @@ public class InsertSyntaxTest extends TestCase {
String text = output(stmtList);
Assert.assertEquals("INSERT LOW_PRIORITY DELAYED HIGH_PRIORITY IGNORE INTO tbl_name (a, b, c) VALUES (1, 2, 3);",
text);
Assert.assertEquals("INSERT LOW_PRIORITY DELAYED HIGH_PRIORITY IGNORE INTO tbl_name (a, b, c) VALUES (1, 2, 3);", text);
}
public void test_6() throws Exception {