提交 326ed1ff authored 作者: Thomas Mueller's avatar Thomas Mueller

Small changes.

上级 b1858d05
...@@ -58,7 +58,7 @@ public class RuleList implements Rule { ...@@ -58,7 +58,7 @@ public class RuleList implements Rule {
} }
} }
return false; return false;
} else { }
for (Rule r : list) { for (Rule r : list) {
if (!r.autoComplete(sentence)) { if (!r.autoComplete(sentence)) {
sentence.setQuery(old); sentence.setQuery(old);
...@@ -67,6 +67,5 @@ public class RuleList implements Rule { ...@@ -67,6 +67,5 @@ public class RuleList implements Rule {
} }
return true; return true;
} }
}
} }
...@@ -4770,7 +4770,7 @@ public class Parser { ...@@ -4770,7 +4770,7 @@ public class Parser {
if (readIf("NO")) { if (readIf("NO")) {
read("ACTION"); read("ACTION");
return ConstraintReferential.RESTRICT; return ConstraintReferential.RESTRICT;
} else { }
read("SET"); read("SET");
if (readIf("NULL")) { if (readIf("NULL")) {
return ConstraintReferential.SET_NULL; return ConstraintReferential.SET_NULL;
...@@ -4778,7 +4778,6 @@ public class Parser { ...@@ -4778,7 +4778,6 @@ public class Parser {
read("DEFAULT"); read("DEFAULT");
return ConstraintReferential.SET_DEFAULT; return ConstraintReferential.SET_DEFAULT;
} }
}
private Integer parseCascadeOrRestrict() { private Integer parseCascadeOrRestrict() {
if (readIf("CASCADE")) { if (readIf("CASCADE")) {
......
...@@ -278,14 +278,13 @@ public class ConnectionInfo implements Cloneable { ...@@ -278,14 +278,13 @@ public class ConnectionInfo implements Cloneable {
private byte[] hashPassword(boolean passwordHash, String userName, char[] password) { private byte[] hashPassword(boolean passwordHash, String userName, char[] password) {
if (passwordHash) { if (passwordHash) {
return StringUtils.convertStringToBytes(new String(password)); return StringUtils.convertStringToBytes(new String(password));
} else { }
if (userName.length() == 0 && password.length == 0 && SysProperties.EMPTY_PASSWORD) { if (userName.length() == 0 && password.length == 0 && SysProperties.EMPTY_PASSWORD) {
return new byte[0]; return new byte[0];
} }
SHA256 sha = new SHA256(); SHA256 sha = new SHA256();
return sha.getKeyPasswordHash(userName, password); return sha.getKeyPasswordHash(userName, password);
} }
}
/** /**
* Get a boolean property if it is set and return the value. * Get a boolean property if it is set and return the value.
......
...@@ -41,9 +41,8 @@ public class FunctionIndex extends BaseIndex { ...@@ -41,9 +41,8 @@ public class FunctionIndex extends BaseIndex {
public Cursor find(Session session, SearchRow first, SearchRow last) { public Cursor find(Session session, SearchRow first, SearchRow last) {
if (functionTable.isFast()) { if (functionTable.isFast()) {
return new FunctionCursorResultSet(session, functionTable.getResultSet(session)); return new FunctionCursorResultSet(session, functionTable.getResultSet(session));
} else {
return new FunctionCursor(functionTable.getResult(session));
} }
return new FunctionCursor(functionTable.getResult(session));
} }
public double getCost(Session session, int[] masks) { public double getCost(Session session, int[] masks) {
......
...@@ -68,9 +68,8 @@ public class DocumentedMBean extends StandardMBean { ...@@ -68,9 +68,8 @@ public class DocumentedMBean extends StandardMBean {
protected int getImpact(MBeanOperationInfo info) { protected int getImpact(MBeanOperationInfo info) {
if (info.getName().startsWith("list")) { if (info.getName().startsWith("list")) {
return MBeanOperationInfo.INFO; return MBeanOperationInfo.INFO;
} else {
return MBeanOperationInfo.ACTION;
} }
return MBeanOperationInfo.ACTION;
} }
} }
...@@ -162,7 +162,7 @@ public class Trace { ...@@ -162,7 +162,7 @@ public class Trace {
*/ */
public void error(Throwable t, String s, Object... params) { public void error(Throwable t, String s, Object... params) {
if (isEnabled(TraceSystem.ERROR)) { if (isEnabled(TraceSystem.ERROR)) {
s = MessageFormat.format(s, (Object[]) params); s = MessageFormat.format(s, params);
traceWriter.write(TraceSystem.ERROR, module, s, t); traceWriter.write(TraceSystem.ERROR, module, s, t);
} }
} }
...@@ -186,7 +186,7 @@ public class Trace { ...@@ -186,7 +186,7 @@ public class Trace {
*/ */
public void info(String s, Object... params) { public void info(String s, Object... params) {
if (isEnabled(TraceSystem.INFO)) { if (isEnabled(TraceSystem.INFO)) {
s = MessageFormat.format(s, (Object[]) params); s = MessageFormat.format(s, params);
traceWriter.write(TraceSystem.INFO, module, s, null); traceWriter.write(TraceSystem.INFO, module, s, null);
} }
} }
...@@ -255,7 +255,7 @@ public class Trace { ...@@ -255,7 +255,7 @@ public class Trace {
*/ */
public void debug(String s, Object... params) { public void debug(String s, Object... params) {
if (isEnabled(TraceSystem.DEBUG)) { if (isEnabled(TraceSystem.DEBUG)) {
s = MessageFormat.format(s, (Object[]) params); s = MessageFormat.format(s, params);
traceWriter.write(TraceSystem.DEBUG, module, s, null); traceWriter.write(TraceSystem.DEBUG, module, s, null);
} }
} }
......
...@@ -422,7 +422,7 @@ public class LobStorage { ...@@ -422,7 +422,7 @@ public class LobStorage {
private long getHashCacheBlock(int hash) { private long getHashCacheBlock(int hash) {
if (HASH_CACHE_SIZE > 0) { if (HASH_CACHE_SIZE > 0) {
int index = (int) (hash & (HASH_CACHE_SIZE - 1)); int index = hash & (HASH_CACHE_SIZE - 1);
long oldHash = hashBlocks[index]; long oldHash = hashBlocks[index];
if (oldHash == hash) { if (oldHash == hash) {
return hashBlocks[index + HASH_CACHE_SIZE]; return hashBlocks[index + HASH_CACHE_SIZE];
...@@ -433,7 +433,7 @@ public class LobStorage { ...@@ -433,7 +433,7 @@ public class LobStorage {
private void setHashCacheBlock(int hash, long block) { private void setHashCacheBlock(int hash, long block) {
if (HASH_CACHE_SIZE > 0) { if (HASH_CACHE_SIZE > 0) {
int index = (int) (hash & (HASH_CACHE_SIZE - 1)); int index = hash & (HASH_CACHE_SIZE - 1);
hashBlocks[index] = hash; hashBlocks[index] = hash;
hashBlocks[index + HASH_CACHE_SIZE] = block; hashBlocks[index + HASH_CACHE_SIZE] = block;
} }
......
...@@ -1492,7 +1492,7 @@ public class PageStore implements CacheWriter { ...@@ -1492,7 +1492,7 @@ public class PageStore implements CacheWriter {
if (add) { if (add) {
addMeta(row, systemSession, true); addMeta(row, systemSession, true);
} else { } else {
removeMeta(logPos, row); removeMeta(row);
} }
} }
Index index = metaObjects.get(tableId); Index index = metaObjects.get(tableId);
...@@ -1565,7 +1565,7 @@ public class PageStore implements CacheWriter { ...@@ -1565,7 +1565,7 @@ public class PageStore implements CacheWriter {
} }
} }
private void removeMeta(int logPos, Row row) { private void removeMeta(Row row) {
int id = row.getValue(0).getInt(); int id = row.getValue(0).getInt();
PageIndex index = metaObjects.get(id); PageIndex index = metaObjects.get(id);
index.getTable().removeIndex(index); index.getTable().removeIndex(index);
......
...@@ -621,7 +621,7 @@ public class TableFilter implements ColumnResolver { ...@@ -621,7 +621,7 @@ public class TableFilter implements ColumnResolver {
do { do {
buffNested.append(n.getPlanSQL(n != nestedJoin)); buffNested.append(n.getPlanSQL(n != nestedJoin));
buffNested.append("\n"); buffNested.append("\n");
n = (TableFilter) n.getJoin(); n = n.getJoin();
} while (n != null); } while (n != null);
buff.append("(\n"); buff.append("(\n");
...@@ -943,7 +943,7 @@ public class TableFilter implements ColumnResolver { ...@@ -943,7 +943,7 @@ public class TableFilter implements ColumnResolver {
if (n != null) { if (n != null) {
n.visit(visitor); n.visit(visitor);
} }
f = (TableFilter) f.join; f = f.join;
} while (f != null); } while (f != null);
} }
......
...@@ -1622,7 +1622,7 @@ public class SimpleResultSet implements ResultSet, ResultSetMetaData { ...@@ -1622,7 +1622,7 @@ public class SimpleResultSet implements ResultSet, ResultSetMetaData {
private void checkColumnIndex(int columnIndex) throws SQLException { private void checkColumnIndex(int columnIndex) throws SQLException {
if (columnIndex < 0 || columnIndex >= columns.size()) { if (columnIndex < 0 || columnIndex >= columns.size()) {
throw DbException.getInvalidValueException("columnIndex", columnIndex).getSQLException(); throw DbException.getInvalidValueException("columnIndex", columnIndex + 1).getSQLException();
} }
} }
......
...@@ -114,9 +114,8 @@ public class CacheTQ implements Cache { ...@@ -114,9 +114,8 @@ public class CacheTQ implements Cache {
public CacheObject update(int pos, CacheObject record) { public CacheObject update(int pos, CacheObject record) {
if (lru.find(pos) != null) { if (lru.find(pos) != null) {
return lru.update(pos, record); return lru.update(pos, record);
} else {
return fifo.update(pos, record);
} }
return fifo.update(pos, record);
} }
} }
...@@ -455,9 +455,8 @@ public class Utils { ...@@ -455,9 +455,8 @@ public class Utils {
in = Utils.class.getResourceAsStream(name); in = Utils.class.getResourceAsStream(name);
if (in == null) { if (in == null) {
return null; return null;
} else {
return IOUtils.readBytesAndClose(in, 0);
} }
return IOUtils.readBytesAndClose(in, 0);
} }
ZipInputStream zipIn = new ZipInputStream(in); ZipInputStream zipIn = new ZipInputStream(in);
try { try {
...@@ -475,9 +474,8 @@ public class Utils { ...@@ -475,9 +474,8 @@ public class Utils {
IOUtils.copy(zipIn, out); IOUtils.copy(zipIn, out);
zipIn.closeEntry(); zipIn.closeEntry();
return out.toByteArray(); return out.toByteArray();
} else {
zipIn.closeEntry();
} }
zipIn.closeEntry();
} }
} catch (IOException e) { } catch (IOException e) {
// if this happens we have a real problem // if this happens we have a real problem
......
...@@ -53,7 +53,7 @@ public class TestMultiDimension extends TestBase { ...@@ -53,7 +53,7 @@ public class TestMultiDimension extends TestBase {
assertEquals(5, m.interleave(new int[]{3, 0})); assertEquals(5, m.interleave(new int[]{3, 0}));
assertEquals(10, m.interleave(0, 3)); assertEquals(10, m.interleave(0, 3));
assertEquals(10, m.interleave(new int[] { 0, 3 })); assertEquals(10, m.interleave(new int[] { 0, 3 }));
long v = (long) Integer.MAX_VALUE | ((long) Integer.MAX_VALUE << 31L); long v = Integer.MAX_VALUE | ((long) Integer.MAX_VALUE << 31L);
assertEquals(v, m.interleave(Integer.MAX_VALUE, Integer.MAX_VALUE)); assertEquals(v, m.interleave(Integer.MAX_VALUE, Integer.MAX_VALUE));
assertEquals(v, m.interleave(new int[] { Integer.MAX_VALUE, Integer.MAX_VALUE })); assertEquals(v, m.interleave(new int[] { Integer.MAX_VALUE, Integer.MAX_VALUE }));
Random random = new Random(1); Random random = new Random(1);
......
...@@ -73,9 +73,8 @@ public class TestLobApi extends TestBase { ...@@ -73,9 +73,8 @@ public class TestLobApi extends TestBase {
if (pos > 100001) { if (pos > 100001) {
if (ioException) { if (ioException) {
throw new IOException(""); throw new IOException("");
} else {
throw new IllegalStateException();
} }
throw new IllegalStateException();
} }
return len; return len;
} }
...@@ -99,9 +98,8 @@ public class TestLobApi extends TestBase { ...@@ -99,9 +98,8 @@ public class TestLobApi extends TestBase {
if (pos > 100001) { if (pos > 100001) {
if (ioException) { if (ioException) {
throw new IOException(""); throw new IOException("");
} else {
throw new IllegalStateException();
} }
throw new IllegalStateException();
} }
return 0; return 0;
} }
......
...@@ -127,14 +127,12 @@ public class TestNestedJoins extends TestBase { ...@@ -127,14 +127,12 @@ public class TestNestedJoins extends TestBase {
// System.out.println(se); // System.out.println(se);
// System.out.println(" " + sql); // System.out.println(" " + sql);
} }
if (e != null) {
if (shortest == null || sql.length() < shortest.length()) { if (shortest == null || sql.length() < shortest.length()) {
shortest = sql; shortest = sql;
shortestEx = e; shortestEx = e;
} }
} }
} }
}
if (shortest != null) { if (shortest != null) {
shortestEx.printStackTrace(); shortestEx.printStackTrace();
fail(shortest + " " + shortestEx); fail(shortest + " " + shortestEx);
...@@ -338,7 +336,7 @@ public class TestNestedJoins extends TestBase { ...@@ -338,7 +336,7 @@ public class TestNestedJoins extends TestBase {
stat.execute("insert into t4 values(1,1), (2,2), (3,3), (4,4)"); stat.execute("insert into t4 values(1,1), (2,2), (3,3), (4,4)");
rs = stat.executeQuery("explain select distinct t1.a, t2.a, t3.a from t1 right outer join t3 on t1.b=t3.a right outer join t2 on t2.b=t1.a"); rs = stat.executeQuery("explain select distinct t1.a, t2.a, t3.a from t1 right outer join t3 on t1.b=t3.a right outer join t2 on t2.b=t1.a");
assertTrue(rs.next()); assertTrue(rs.next());
sql = cleanRemarks(conn, rs.getString(1)); sql = cleanRemarks(rs.getString(1));
assertEquals("SELECT DISTINCT T1.A, T2.A, T3.A FROM PUBLIC.T2 LEFT OUTER JOIN ( PUBLIC.T3 LEFT OUTER JOIN ( PUBLIC.T1 ) ON T1.B = T3.A ) ON T2.B = T1.A", sql); assertEquals("SELECT DISTINCT T1.A, T2.A, T3.A FROM PUBLIC.T2 LEFT OUTER JOIN ( PUBLIC.T3 LEFT OUTER JOIN ( PUBLIC.T1 ) ON T1.B = T3.A ) ON T2.B = T1.A", sql);
rs = stat.executeQuery("select distinct t1.a, t2.a, t3.a from t1 right outer join t3 on t1.b=t3.a right outer join t2 on t2.b=t1.a"); rs = stat.executeQuery("select distinct t1.a, t2.a, t3.a from t1 right outer join t3 on t1.b=t3.a right outer join t2 on t2.b=t1.a");
// expected: 1 1 1; null 2 null // expected: 1 1 1; null 2 null
...@@ -372,7 +370,7 @@ public class TestNestedJoins extends TestBase { ...@@ -372,7 +370,7 @@ public class TestNestedJoins extends TestBase {
stat.execute("insert into c values(1), (2)"); stat.execute("insert into c values(1), (2)");
rs = stat.executeQuery("explain select a.x, b.x, c.x from a inner join b on a.x = b.x right outer join c on c.x = a.x"); rs = stat.executeQuery("explain select a.x, b.x, c.x from a inner join b on a.x = b.x right outer join c on c.x = a.x");
assertTrue(rs.next()); assertTrue(rs.next());
sql = cleanRemarks(conn, rs.getString(1)); sql = cleanRemarks(rs.getString(1));
assertEquals("SELECT A.X, B.X, C.X FROM PUBLIC.C LEFT OUTER JOIN ( PUBLIC.A INNER JOIN PUBLIC.B ON A.X = B.X ) ON C.X = A.X", sql); assertEquals("SELECT A.X, B.X, C.X FROM PUBLIC.C LEFT OUTER JOIN ( PUBLIC.A INNER JOIN PUBLIC.B ON A.X = B.X ) ON C.X = A.X", sql);
rs = stat.executeQuery("select a.x, b.x, c.x from a inner join b on a.x = b.x right outer join c on c.x = a.x"); rs = stat.executeQuery("select a.x, b.x, c.x from a inner join b on a.x = b.x right outer join c on c.x = a.x");
// expected result: 1 1 1; null null 2 // expected result: 1 1 1; null null 2
...@@ -414,7 +412,7 @@ public class TestNestedJoins extends TestBase { ...@@ -414,7 +412,7 @@ public class TestNestedJoins extends TestBase {
"on b.x = c.y) " + "on b.x = c.y) " +
"on a.x = c.x"); "on a.x = c.x");
assertTrue(rs.next()); assertTrue(rs.next());
sql = cleanRemarks(conn, rs.getString(1)); sql = cleanRemarks(rs.getString(1));
assertEquals("SELECT A.X, B.X, C.X, C.Y FROM PUBLIC.A " + assertEquals("SELECT A.X, B.X, C.X, C.Y FROM PUBLIC.A " +
"LEFT OUTER JOIN ( PUBLIC.B " + "LEFT OUTER JOIN ( PUBLIC.B " +
"LEFT OUTER JOIN PUBLIC.C " + "LEFT OUTER JOIN PUBLIC.C " +
...@@ -495,7 +493,7 @@ public class TestNestedJoins extends TestBase { ...@@ -495,7 +493,7 @@ public class TestNestedJoins extends TestBase {
"left outer join (b " + "left outer join (b " +
"inner join c on c.x = 1) on a.x = b.x"); "inner join c on c.x = 1) on a.x = b.x");
assertTrue(rs.next()); assertTrue(rs.next());
sql = cleanRemarks(conn, rs.getString(1)); sql = cleanRemarks(rs.getString(1));
assertEquals("SELECT A.X, B.X, C.X FROM PUBLIC.A " + assertEquals("SELECT A.X, B.X, C.X FROM PUBLIC.A " +
"LEFT OUTER JOIN ( PUBLIC.B " + "LEFT OUTER JOIN ( PUBLIC.B " +
"INNER JOIN PUBLIC.C ON C.X = 1 ) ON A.X = B.X", sql); "INNER JOIN PUBLIC.C ON C.X = 1 ) ON A.X = B.X", sql);
...@@ -541,7 +539,7 @@ public class TestNestedJoins extends TestBase { ...@@ -541,7 +539,7 @@ public class TestNestedJoins extends TestBase {
"left outer join (b inner join base b_base " + "left outer join (b inner join base b_base " +
"on b.pk = b_base.pk and b_base.deleted = 0) on 1=1"); "on b.pk = b_base.pk and b_base.deleted = 0) on 1=1");
assertTrue(rs.next()); assertTrue(rs.next());
sql = cleanRemarks(conn, rs.getString(1)); sql = cleanRemarks(rs.getString(1));
assertEquals("SELECT A.PK, A_BASE.PK, B.PK, B_BASE.PK FROM PUBLIC.BASE A_BASE " + assertEquals("SELECT A.PK, A_BASE.PK, B.PK, B_BASE.PK FROM PUBLIC.BASE A_BASE " +
"LEFT OUTER JOIN ( PUBLIC.B " + "LEFT OUTER JOIN ( PUBLIC.B " +
"INNER JOIN PUBLIC.BASE B_BASE " + "INNER JOIN PUBLIC.BASE B_BASE " +
...@@ -571,7 +569,7 @@ public class TestNestedJoins extends TestBase { ...@@ -571,7 +569,7 @@ public class TestNestedJoins extends TestBase {
deleteDb("nestedJoins"); deleteDb("nestedJoins");
} }
private String cleanRemarks(Connection conn, String sql) throws SQLException { private String cleanRemarks(String sql) throws SQLException {
ScriptReader r = new ScriptReader(new StringReader(sql)); ScriptReader r = new ScriptReader(new StringReader(sql));
r.setSkipRemarks(true); r.setSkipRemarks(true);
sql = r.readStatement(); sql = r.readStatement();
......
...@@ -118,14 +118,12 @@ public class TestOuterJoins extends TestBase { ...@@ -118,14 +118,12 @@ public class TestOuterJoins extends TestBase {
// SQLException se = (SQLException) e; // SQLException se = (SQLException) e;
// System.out.println(se); // System.out.println(se);
} }
if (e != null) {
if (shortest == null || sql.length() < shortest.length()) { if (shortest == null || sql.length() < shortest.length()) {
shortest = sql; shortest = sql;
shortestEx = e; shortestEx = e;
} }
} }
} }
}
if (shortest != null) { if (shortest != null) {
shortestEx.printStackTrace(); shortestEx.printStackTrace();
fail(shortest + " " + shortestEx); fail(shortest + " " + shortestEx);
...@@ -330,7 +328,7 @@ public class TestOuterJoins extends TestBase { ...@@ -330,7 +328,7 @@ public class TestOuterJoins extends TestBase {
stat.execute("insert into t4 values(1,1), (2,2), (3,3), (4,4)"); stat.execute("insert into t4 values(1,1), (2,2), (3,3), (4,4)");
rs = stat.executeQuery("explain select distinct t1.a, t2.a, t3.a from t1 right outer join t3 on t1.b=t3.a right outer join t2 on t2.b=t1.a"); rs = stat.executeQuery("explain select distinct t1.a, t2.a, t3.a from t1 right outer join t3 on t1.b=t3.a right outer join t2 on t2.b=t1.a");
assertTrue(rs.next()); assertTrue(rs.next());
sql = cleanRemarks(conn, rs.getString(1)); sql = cleanRemarks(rs.getString(1));
assertEquals("SELECT DISTINCT T1.A, T2.A, T3.A FROM PUBLIC.T2 LEFT OUTER JOIN ( PUBLIC.T3 LEFT OUTER JOIN ( PUBLIC.T1 ) ON T1.B = T3.A ) ON T2.B = T1.A", sql); assertEquals("SELECT DISTINCT T1.A, T2.A, T3.A FROM PUBLIC.T2 LEFT OUTER JOIN ( PUBLIC.T3 LEFT OUTER JOIN ( PUBLIC.T1 ) ON T1.B = T3.A ) ON T2.B = T1.A", sql);
rs = stat.executeQuery("select distinct t1.a, t2.a, t3.a from t1 right outer join t3 on t1.b=t3.a right outer join t2 on t2.b=t1.a"); rs = stat.executeQuery("select distinct t1.a, t2.a, t3.a from t1 right outer join t3 on t1.b=t3.a right outer join t2 on t2.b=t1.a");
// expected: 1 1 1; null 2 null // expected: 1 1 1; null 2 null
...@@ -364,7 +362,7 @@ public class TestOuterJoins extends TestBase { ...@@ -364,7 +362,7 @@ public class TestOuterJoins extends TestBase {
stat.execute("insert into c values(1), (2)"); stat.execute("insert into c values(1), (2)");
rs = stat.executeQuery("explain select a.x, b.x, c.x from a inner join b on a.x = b.x right outer join c on c.x = a.x"); rs = stat.executeQuery("explain select a.x, b.x, c.x from a inner join b on a.x = b.x right outer join c on c.x = a.x");
assertTrue(rs.next()); assertTrue(rs.next());
sql = cleanRemarks(conn, rs.getString(1)); sql = cleanRemarks(rs.getString(1));
assertEquals("SELECT A.X, B.X, C.X FROM PUBLIC.C LEFT OUTER JOIN ( PUBLIC.A INNER JOIN PUBLIC.B ON A.X = B.X ) ON C.X = A.X", sql); assertEquals("SELECT A.X, B.X, C.X FROM PUBLIC.C LEFT OUTER JOIN ( PUBLIC.A INNER JOIN PUBLIC.B ON A.X = B.X ) ON C.X = A.X", sql);
rs = stat.executeQuery("select a.x, b.x, c.x from a inner join b on a.x = b.x right outer join c on c.x = a.x"); rs = stat.executeQuery("select a.x, b.x, c.x from a inner join b on a.x = b.x right outer join c on c.x = a.x");
// expected result: 1 1 1; null null 2 // expected result: 1 1 1; null null 2
...@@ -406,7 +404,7 @@ public class TestOuterJoins extends TestBase { ...@@ -406,7 +404,7 @@ public class TestOuterJoins extends TestBase {
"on b.x = c.y) " + "on b.x = c.y) " +
"on a.x = c.x"); "on a.x = c.x");
assertTrue(rs.next()); assertTrue(rs.next());
sql = cleanRemarks(conn, rs.getString(1)); sql = cleanRemarks(rs.getString(1));
assertEquals("SELECT A.X, B.X, C.X, C.Y FROM PUBLIC.A " + assertEquals("SELECT A.X, B.X, C.X, C.Y FROM PUBLIC.A " +
"LEFT OUTER JOIN ( PUBLIC.B " + "LEFT OUTER JOIN ( PUBLIC.B " +
"LEFT OUTER JOIN PUBLIC.C " + "LEFT OUTER JOIN PUBLIC.C " +
...@@ -487,7 +485,7 @@ public class TestOuterJoins extends TestBase { ...@@ -487,7 +485,7 @@ public class TestOuterJoins extends TestBase {
"left outer join (b " + "left outer join (b " +
"inner join c on c.x = 1) on a.x = b.x"); "inner join c on c.x = 1) on a.x = b.x");
assertTrue(rs.next()); assertTrue(rs.next());
sql = cleanRemarks(conn, rs.getString(1)); sql = cleanRemarks(rs.getString(1));
assertEquals("SELECT A.X, B.X, C.X FROM PUBLIC.A " + assertEquals("SELECT A.X, B.X, C.X FROM PUBLIC.A " +
"LEFT OUTER JOIN ( PUBLIC.B " + "LEFT OUTER JOIN ( PUBLIC.B " +
"INNER JOIN PUBLIC.C ON C.X = 1 ) ON A.X = B.X", sql); "INNER JOIN PUBLIC.C ON C.X = 1 ) ON A.X = B.X", sql);
...@@ -533,7 +531,7 @@ public class TestOuterJoins extends TestBase { ...@@ -533,7 +531,7 @@ public class TestOuterJoins extends TestBase {
"left outer join (b inner join base b_base " + "left outer join (b inner join base b_base " +
"on b.pk = b_base.pk and b_base.deleted = 0) on 1=1"); "on b.pk = b_base.pk and b_base.deleted = 0) on 1=1");
assertTrue(rs.next()); assertTrue(rs.next());
sql = cleanRemarks(conn, rs.getString(1)); sql = cleanRemarks(rs.getString(1));
assertEquals("SELECT A.PK, A_BASE.PK, B.PK, B_BASE.PK FROM PUBLIC.BASE A_BASE " + assertEquals("SELECT A.PK, A_BASE.PK, B.PK, B_BASE.PK FROM PUBLIC.BASE A_BASE " +
"LEFT OUTER JOIN ( PUBLIC.B " + "LEFT OUTER JOIN ( PUBLIC.B " +
"INNER JOIN PUBLIC.BASE B_BASE " + "INNER JOIN PUBLIC.BASE B_BASE " +
...@@ -563,7 +561,7 @@ public class TestOuterJoins extends TestBase { ...@@ -563,7 +561,7 @@ public class TestOuterJoins extends TestBase {
deleteDb("nestedJoins"); deleteDb("nestedJoins");
} }
private String cleanRemarks(Connection conn, String sql) throws SQLException { private String cleanRemarks(String sql) throws SQLException {
ScriptReader r = new ScriptReader(new StringReader(sql)); ScriptReader r = new ScriptReader(new StringReader(sql));
r.setSkipRemarks(true); r.setSkipRemarks(true);
sql = r.readStatement(); sql = r.readStatement();
......
...@@ -104,14 +104,12 @@ public class TestRandomCompare extends TestBase { ...@@ -104,14 +104,12 @@ public class TestRandomCompare extends TestBase {
// System.out.println(se); // System.out.println(se);
// System.out.println(" " + sql); // System.out.println(" " + sql);
} }
if (e != null) {
if (shortest == null || sql.length() < shortest.length()) { if (shortest == null || sql.length() < shortest.length()) {
shortest = sql; shortest = sql;
shortestEx = e; shortestEx = e;
} }
} }
} }
}
if (shortest != null) { if (shortest != null) {
shortestEx.printStackTrace(); shortestEx.printStackTrace();
fail(shortest + " " + shortestEx); fail(shortest + " " + shortestEx);
......
...@@ -165,7 +165,6 @@ public class TestCache extends TestBase implements CacheWriter { ...@@ -165,7 +165,6 @@ public class TestCache extends TestBase implements CacheWriter {
conn.close(); conn.close();
stat = null; stat = null;
conn = null; conn = null;
rs = null;
long afterClose = getRealMemory(); long afterClose = getRealMemory();
trace("Used memory: " + (afterInsert - afterClose) + " calculated cache size: " + calculated); trace("Used memory: " + (afterInsert - afterClose) + " calculated cache size: " + calculated);
trace("Before: " + before + " after: " + afterInsert + " after closing: " + afterClose); trace("Before: " + before + " after: " + afterInsert + " after closing: " + afterClose);
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论