Unverified 提交 542100a4 authored 作者: Evgenij Ryazanov's avatar Evgenij Ryazanov 提交者: GitHub

Merge pull request #1126 from katzyn/misc

Fix an issue with code coverage and building of documentation
...@@ -21,12 +21,38 @@ Change Log ...@@ -21,12 +21,38 @@ Change Log
<h2>Next Version (unreleased)</h2> <h2>Next Version (unreleased)</h2>
<ul> <ul>
<li>PR #1126: Fix an issue with code coverage and building of documentation
</li>
<li>PR #1123: Fix TCP version check
</li>
<li>PR #1122: Assorted changes
</li>
<li>PR #1121: Add some protection to ValueHashMap against hashes with the same less significant bits
</li>
<li>Issue #1097: H2 10x slower than HSQLDB and 6x than Apache Derby for specific query with GROUP BY and DISTINCT subquery
</li>
<li>Issue #1093: Use temporary files for ResultSet buffer tables in MVStore
</li>
<li>PR #1117: Fix sorting with distinct in ResultTempTable
</li>
<li>Issue #1095: Add support for INSERT IGNORE INTO &lt;table&gt; (&lt;columns&gt;) SELECT in MySQL Mode
</li>
<li>PR #1114: Minor cleanup and formatting fixes
</li>
<li>PR #1112: Improve test scripts
</li>
<li>PR #1111: Use a better fix for issue with SRID
</li>
<li>Issue #1107: Restore support of DATETIME2 with specified fractional seconds precision
</li>
<li>Issue #1106: Get rid of SwitchSource <li>Issue #1106: Get rid of SwitchSource
</li> </li>
<li>PR #1105: Assorted minor changes <li>PR #1105: Assorted minor changes
</li> </li>
<li>Issue #1102: CREATE SYNONYM rejects valid definition <li>Issue #1102: CREATE SYNONYM rejects valid definition
</li> </li>
<li>PR #1103: Remove redundant synchronization
</li>
<li>Issue #1048: 1.4.197 regression. org.h2.jdbc.JdbcSQLException: Timeout trying to lock table "SYS" <li>Issue #1048: 1.4.197 regression. org.h2.jdbc.JdbcSQLException: Timeout trying to lock table "SYS"
</li> </li>
<li>PR #1101: Move some tests in better place and add an additional test for 2PC <li>PR #1101: Move some tests in better place and add an additional test for 2PC
...@@ -43,8 +69,16 @@ Change Log ...@@ -43,8 +69,16 @@ Change Log
</li> </li>
<li>PR #1087: improve performance of planning large queries <li>PR #1087: improve performance of planning large queries
</li> </li>
<li>PR #1085: Add tests for simple one-column index sorting
</li>
<li>PR #1084: re-enable some pagestore testing
</li>
<li>PR #1083: Assorted changes
</li>
<li>Issue #394: Recover tool places COLLATION and BINARY_COLLATION after temporary tables <li>Issue #394: Recover tool places COLLATION and BINARY_COLLATION after temporary tables
</li> </li>
<li>PR #1081: Session.getTransactionId should return a more distinguishing value
</li>
<li>Improve the script-based unit testing to check the error code of the exception thrown. <li>Improve the script-based unit testing to check the error code of the exception thrown.
</li> </li>
<li>Issue #1041: Support OR syntax while creating trigger <li>Issue #1041: Support OR syntax while creating trigger
......
...@@ -394,7 +394,7 @@ public class Insert extends Prepared implements ResultTarget { ...@@ -394,7 +394,7 @@ public class Insert extends Prepared implements ResultTarget {
ArrayList<String> variableNames = new ArrayList<>( ArrayList<String> variableNames = new ArrayList<>(
duplicateKeyAssignmentMap.size()); duplicateKeyAssignmentMap.size());
Expression[] row = (currentRow == null) ? list.get(getCurrentRowNumber() - 1) Expression[] row = (currentRow == null) ? list.get(getCurrentRowNumber() - 1)
: new Expression[columns.length]; : new Expression[columns.length];
for (int i = 0; i < columns.length; i++) { for (int i = 0; i < columns.length; i++) {
String key = table.getSchema().getName() + "." + String key = table.getSchema().getName() + "." +
......
...@@ -106,7 +106,8 @@ public class Select extends Query { ...@@ -106,7 +106,8 @@ public class Select extends Query {
*/ */
Object[] currentGroupByExprData; Object[] currentGroupByExprData;
/** /**
* Maps an expression object to an index, to use in accessing the Object[] pointed to by groupByData. * Maps an expression object to an index, to use in accessing the Object[]
* pointed to by groupByData.
*/ */
final HashMap<Expression,Integer> exprToIndexInGroupByData = new HashMap<>(); final HashMap<Expression,Integer> exprToIndexInGroupByData = new HashMap<>();
/** /**
...@@ -117,7 +118,7 @@ public class Select extends Query { ...@@ -117,7 +118,7 @@ public class Select extends Query {
* Key into groupByData that produces currentGroupByExprData. Not used in lazy mode. * Key into groupByData that produces currentGroupByExprData. Not used in lazy mode.
*/ */
ValueArray currentGroupsKey; ValueArray currentGroupsKey;
private int havingIndex; private int havingIndex;
private boolean isGroupQuery, isGroupSortedQuery; private boolean isGroupQuery, isGroupSortedQuery;
private boolean isForUpdate, isForUpdateMvcc; private boolean isForUpdate, isForUpdateMvcc;
...@@ -1580,11 +1581,13 @@ public class Select extends Query { ...@@ -1580,11 +1581,13 @@ public class Select extends Query {
Value[] row = null; Value[] row = null;
if (previousKeyValues == null) { if (previousKeyValues == null) {
previousKeyValues = keyValues; previousKeyValues = keyValues;
currentGroupByExprData = new Object[Math.max(exprToIndexInGroupByData.size(), expressions.size())]; currentGroupByExprData =new Object[Math.max(exprToIndexInGroupByData.size(),
expressions.size())];
} else if (!Arrays.equals(previousKeyValues, keyValues)) { } else if (!Arrays.equals(previousKeyValues, keyValues)) {
row = createGroupSortedRow(previousKeyValues, columnCount); row = createGroupSortedRow(previousKeyValues, columnCount);
previousKeyValues = keyValues; previousKeyValues = keyValues;
currentGroupByExprData = new Object[Math.max(exprToIndexInGroupByData.size(), expressions.size())]; currentGroupByExprData = new Object[Math.max(exprToIndexInGroupByData.size(),
expressions.size())];
} }
currentGroupRowId++; currentGroupRowId++;
......
...@@ -934,7 +934,8 @@ public class Database implements DataHandler { ...@@ -934,7 +934,8 @@ public class Database implements DataHandler {
} }
if (SysProperties.CHECK2) { if (SysProperties.CHECK2) {
// If we are locking two different databases in the same stack, just ignore it. // If we are locking two different databases in the same stack, just ignore it.
// This only happens in TestLinkedTable where we connect to another h2 DB in the same process. // This only happens in TestLinkedTable where we connect to another h2 DB in the
// same process.
if (META_LOCK_DEBUGGING_DB.get() != null if (META_LOCK_DEBUGGING_DB.get() != null
&& META_LOCK_DEBUGGING_DB.get() != this) { && META_LOCK_DEBUGGING_DB.get() != this) {
final Session prev = META_LOCK_DEBUGGING.get(); final Session prev = META_LOCK_DEBUGGING.get();
......
...@@ -371,8 +371,8 @@ public class Aggregate extends Expression { ...@@ -371,8 +371,8 @@ public class Aggregate extends Expression {
DbException.throwInternalError("type=" + type); DbException.throwInternalError("type=" + type);
} }
} }
if (!select.isCurrentGroup()) { if (!select.isCurrentGroup()) {
throw DbException.get(ErrorCode.INVALID_USE_OF_AGGREGATE_FUNCTION_1, getSQL()); throw DbException.get(ErrorCode.INVALID_USE_OF_AGGREGATE_FUNCTION_1, getSQL());
} }
AggregateData data = (AggregateData)select.getCurrentGroupExprData(this); AggregateData data = (AggregateData)select.getCurrentGroupExprData(this);
if (data == null) { if (data == null) {
......
...@@ -312,9 +312,10 @@ public class PageDataIndex extends PageIndex { ...@@ -312,9 +312,10 @@ public class PageDataIndex extends PageIndex {
public double getCost(Session session, int[] masks, public double getCost(Session session, int[] masks,
TableFilter[] filters, int filter, SortOrder sortOrder, TableFilter[] filters, int filter, SortOrder sortOrder,
AllColumnsForPlan allColumnsSet) { AllColumnsForPlan allColumnsSet) {
// The +200 is so that indexes that can return the same data, but have less columns, will take precedence. // The +200 is so that indexes that can return the same data, but have less
// This all works out easier in the MVStore case, because MVStore uses the same cost calculation // columns, will take precedence. This all works out easier in the MVStore case,
// code for the ScanIndex (i.e. the MVPrimaryIndex) and all other indices. // because MVStore uses the same cost calculation code for the ScanIndex (i.e.
// the MVPrimaryIndex) and all other indices.
return 10 * (tableData.getRowCountApproximation() + return 10 * (tableData.getRowCountApproximation() +
Constants.COST_ROW_OFFSET) + 200; Constants.COST_ROW_OFFSET) + 200;
} }
......
...@@ -459,8 +459,8 @@ public class RegularTable extends TableBase { ...@@ -459,8 +459,8 @@ public class RegularTable extends TableBase {
return true; return true;
} }
if (!exclusive && lockSharedSessions.containsKey(session)) { if (!exclusive && lockSharedSessions.containsKey(session)) {
return true; return true;
} }
synchronized (database) { synchronized (database) {
if (!exclusive && lockSharedSessions.contains(session)) { if (!exclusive && lockSharedSessions.contains(session)) {
return true; return true;
......
...@@ -192,11 +192,11 @@ public class ValueHashMap<V> extends HashBase { ...@@ -192,11 +192,11 @@ public class ValueHashMap<V> extends HashBase {
} }
return list; return list;
} }
public Iterable<Map.Entry<Value, V>> entries() { public Iterable<Map.Entry<Value, V>> entries() {
return new EntryIterable(); return new EntryIterable();
} }
private final class EntryIterable implements Iterable<Map.Entry<Value, V>> { private final class EntryIterable implements Iterable<Map.Entry<Value, V>> {
EntryIterable() { EntryIterable() {
} }
...@@ -228,10 +228,10 @@ public class ValueHashMap<V> extends HashBase { ...@@ -228,10 +228,10 @@ public class ValueHashMap<V> extends HashBase {
keysIndex++; keysIndex++;
Value key = keys[keysIndex]; Value key = keys[keysIndex];
if (key != null && key != ValueNull.DELETED) if (key != null && key != ValueNull.DELETED)
return new AbstractMap.SimpleImmutableEntry<Value, V>(key, values[keysIndex]); return new AbstractMap.SimpleImmutableEntry<>(key, values[keysIndex]);
} }
} }
@Override @Override
public void remove() { public void remove() {
throw new UnsupportedOperationException(); throw new UnsupportedOperationException();
......
...@@ -28,7 +28,8 @@ public class TestBigResult extends TestBase { ...@@ -28,7 +28,8 @@ public class TestBigResult extends TestBase {
/** /**
* Run just this test. * Run just this test.
* *
* @param a ignored * @param a
* ignored
*/ */
public static void main(String... a) throws Exception { public static void main(String... a) throws Exception {
TestBase.createCaller().init().test(); TestBase.createCaller().init().test();
...@@ -56,13 +57,11 @@ public class TestBigResult extends TestBase { ...@@ -56,13 +57,11 @@ public class TestBigResult extends TestBase {
int len = getSize(1000, 4000); int len = getSize(1000, 4000);
stat.execute("SET MAX_MEMORY_ROWS " + (len / 10)); stat.execute("SET MAX_MEMORY_ROWS " + (len / 10));
stat.execute("CREATE TABLE RECOVERY(TRANSACTION_ID INT, SQL_STMT VARCHAR)"); stat.execute("CREATE TABLE RECOVERY(TRANSACTION_ID INT, SQL_STMT VARCHAR)");
stat.execute("INSERT INTO RECOVERY " + stat.execute("INSERT INTO RECOVERY " + "SELECT X, CASE MOD(X, 2) WHEN 0 THEN 'commit' ELSE 'begin' END "
"SELECT X, CASE MOD(X, 2) WHEN 0 THEN 'commit' ELSE 'begin' END " + + "FROM SYSTEM_RANGE(1, " + len + ")");
"FROM SYSTEM_RANGE(1, "+len+")"); ResultSet rs = stat.executeQuery("SELECT * FROM RECOVERY " + "WHERE SQL_STMT LIKE 'begin%' AND "
ResultSet rs = stat.executeQuery("SELECT * FROM RECOVERY " + + "TRANSACTION_ID NOT IN(SELECT TRANSACTION_ID FROM RECOVERY "
"WHERE SQL_STMT LIKE 'begin%' AND " + + "WHERE SQL_STMT='commit' OR SQL_STMT='rollback')");
"TRANSACTION_ID NOT IN(SELECT TRANSACTION_ID FROM RECOVERY " +
"WHERE SQL_STMT='commit' OR SQL_STMT='rollback')");
int count = 0, last = 1; int count = 0, last = 1;
while (rs.next()) { while (rs.next()) {
assertEquals(last, rs.getInt(1)); assertEquals(last, rs.getInt(1));
...@@ -86,9 +85,9 @@ public class TestBigResult extends TestBase { ...@@ -86,9 +85,9 @@ public class TestBigResult extends TestBase {
ps.executeUpdate(); ps.executeUpdate();
} }
// local result // local result
testSortintAndDistinct1(stat, count, count); testSortingAndDistinct1(stat, count, count);
// external result // external result
testSortintAndDistinct1(stat, 10, count); testSortingAndDistinct1(stat, 10, count);
stat.execute("DROP TABLE TEST"); stat.execute("DROP TABLE TEST");
stat.execute("CREATE TABLE TEST(ID INT PRIMARY KEY, VALUE1 INT NOT NULL, VALUE2 INT NOT NULL)"); stat.execute("CREATE TABLE TEST(ID INT PRIMARY KEY, VALUE1 INT NOT NULL, VALUE2 INT NOT NULL)");
ps = conn.prepareStatement("INSERT INTO TEST VALUES (?, ?, ?)"); ps = conn.prepareStatement("INSERT INTO TEST VALUES (?, ?, ?)");
...@@ -182,7 +181,7 @@ public class TestBigResult extends TestBase { ...@@ -182,7 +181,7 @@ public class TestBigResult extends TestBase {
conn.close(); conn.close();
} }
private void testSortintAndDistinct1(Statement stat, int maxRows, int count) throws SQLException { private void testSortingAndDistinct1(Statement stat, int maxRows, int count) throws SQLException {
stat.execute("SET MAX_MEMORY_ROWS " + maxRows); stat.execute("SET MAX_MEMORY_ROWS " + maxRows);
ResultSet rs = stat.executeQuery("SELECT VALUE FROM (SELECT DISTINCT ID, VALUE FROM TEST ORDER BY VALUE)"); ResultSet rs = stat.executeQuery("SELECT VALUE FROM (SELECT DISTINCT ID, VALUE FROM TEST ORDER BY VALUE)");
for (int i = 1; i <= count; i++) { for (int i = 1; i <= count; i++) {
...@@ -209,7 +208,8 @@ public class TestBigResult extends TestBase { ...@@ -209,7 +208,8 @@ public class TestBigResult extends TestBase {
assertFalse(rs.next()); assertFalse(rs.next());
} }
private void testSortingAndDistinct2DistinctOnly(Statement stat, String sql, int maxRows, int partCount) throws SQLException { private void testSortingAndDistinct2DistinctOnly(Statement stat, String sql, int maxRows, int partCount)
throws SQLException {
ResultSet rs; ResultSet rs;
stat.execute("SET MAX_MEMORY_ROWS " + maxRows); stat.execute("SET MAX_MEMORY_ROWS " + maxRows);
rs = stat.executeQuery(sql); rs = stat.executeQuery(sql);
...@@ -235,7 +235,8 @@ public class TestBigResult extends TestBase { ...@@ -235,7 +235,8 @@ public class TestBigResult extends TestBase {
assertFalse(rs.next()); assertFalse(rs.next());
} }
private void testSortingAndDistinct3DistinctOnly(Statement stat, String sql, int maxRows, int partCount) throws SQLException { private void testSortingAndDistinct3DistinctOnly(Statement stat, String sql, int maxRows, int partCount)
throws SQLException {
ResultSet rs; ResultSet rs;
stat.execute("SET MAX_MEMORY_ROWS " + maxRows); stat.execute("SET MAX_MEMORY_ROWS " + maxRows);
rs = stat.executeQuery(sql); rs = stat.executeQuery(sql);
...@@ -261,7 +262,8 @@ public class TestBigResult extends TestBase { ...@@ -261,7 +262,8 @@ public class TestBigResult extends TestBase {
assertFalse(rs.next()); assertFalse(rs.next());
} }
private void testSortingAndDistinct4DistinctOnly(Statement stat, String sql, int maxRows, int count) throws SQLException { private void testSortingAndDistinct4DistinctOnly(Statement stat, String sql, int maxRows, int count)
throws SQLException {
stat.execute("SET MAX_MEMORY_ROWS " + maxRows); stat.execute("SET MAX_MEMORY_ROWS " + maxRows);
ResultSet rs = stat.executeQuery(sql); ResultSet rs = stat.executeQuery(sql);
BitSet set = new BitSet(); BitSet set = new BitSet();
...@@ -278,7 +280,8 @@ public class TestBigResult extends TestBase { ...@@ -278,7 +280,8 @@ public class TestBigResult extends TestBase {
assertEquals(count, set.nextClearBit(0)); assertEquals(count, set.nextClearBit(0));
} }
private void testSortingAndDistinct4SortingOnly(Statement stat, String sql, int maxRows, int count) throws SQLException { private void testSortingAndDistinct4SortingOnly(Statement stat, String sql, int maxRows, int count)
throws SQLException {
stat.execute("SET MAX_MEMORY_ROWS " + maxRows); stat.execute("SET MAX_MEMORY_ROWS " + maxRows);
ResultSet rs = stat.executeQuery(sql); ResultSet rs = stat.executeQuery(sql);
for (int i = 0; i < count; i++) { for (int i = 0; i < count; i++) {
...@@ -377,8 +380,7 @@ public class TestBigResult extends TestBase { ...@@ -377,8 +380,7 @@ public class TestBigResult extends TestBase {
// rs.close(); // rs.close();
conn.close(); conn.close();
deleteDb("bigResult"); deleteDb("bigResult");
ArrayList<String> files = FileLister.getDatabaseFiles(getBaseDir(), ArrayList<String> files = FileLister.getDatabaseFiles(getBaseDir(), "bigResult", true);
"bigResult", true);
if (files.size() > 0) { if (files.size() > 0) {
fail("file not deleted: " + files.get(0)); fail("file not deleted: " + files.get(0));
} }
...@@ -415,15 +417,10 @@ public class TestBigResult extends TestBase { ...@@ -415,15 +417,10 @@ public class TestBigResult extends TestBase {
Connection conn = getConnection("bigResult"); Connection conn = getConnection("bigResult");
Statement stat = conn.createStatement(); Statement stat = conn.createStatement();
stat.execute("DROP TABLE IF EXISTS TEST"); stat.execute("DROP TABLE IF EXISTS TEST");
stat.execute("CREATE TABLE TEST(" + stat.execute("CREATE TABLE TEST(" + "ID INT PRIMARY KEY, " + "Name VARCHAR(255), " + "FirstName VARCHAR(255), "
"ID INT PRIMARY KEY, " + + "Points INT," + "LicenseID INT)");
"Name VARCHAR(255), " +
"FirstName VARCHAR(255), " +
"Points INT," +
"LicenseID INT)");
int len = getSize(10, 5000); int len = getSize(10, 5000);
PreparedStatement prep = conn.prepareStatement( PreparedStatement prep = conn.prepareStatement("INSERT INTO TEST VALUES(?, ?, ?, ?, ?)");
"INSERT INTO TEST VALUES(?, ?, ?, ?, ?)");
for (int i = 0; i < len; i++) { for (int i = 0; i < len; i++) {
prep.setInt(1, i); prep.setInt(1, i);
prep.setString(2, "Name " + i); prep.setString(2, "Name " + i);
...@@ -474,8 +471,7 @@ public class TestBigResult extends TestBase { ...@@ -474,8 +471,7 @@ public class TestBigResult extends TestBase {
prep.setString(2, "" + i / 200); prep.setString(2, "" + i / 200);
prep.execute(); prep.execute();
} }
Statement s2 = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, Statement s2 = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE);
ResultSet.CONCUR_UPDATABLE);
rs = s2.executeQuery("SELECT NAME FROM DATA"); rs = s2.executeQuery("SELECT NAME FROM DATA");
rs.last(); rs.last();
conn.setAutoCommit(true); conn.setAutoCommit(true);
......
...@@ -492,11 +492,11 @@ public class TestScript extends TestBase { ...@@ -492,11 +492,11 @@ public class TestScript extends TestBase {
} }
/** Convert the error code to a symbolic name from ErrorCode. */ /** Convert the error code to a symbolic name from ErrorCode. */
private static final Map<Integer, String> ERROR_CODE_TO_NAME = new HashMap<>(); private static final Map<Integer, String> ERROR_CODE_TO_NAME = new HashMap<>(256);
static { static {
try { try {
for (Field field : ErrorCode.class.getDeclaredFields()) { for (Field field : ErrorCode.class.getDeclaredFields()) {
if (Modifier.isStatic(field.getModifiers())) { if (field.getModifiers() == (Modifier.PUBLIC | Modifier.STATIC | Modifier.FINAL)) {
ERROR_CODE_TO_NAME.put(field.getInt(null), field.getName()); ERROR_CODE_TO_NAME.put(field.getInt(null), field.getName());
} }
} }
......
...@@ -775,3 +775,4 @@ iterators tech enums incompatibilities loses reimplement readme reorganize milli ...@@ -775,3 +775,4 @@ iterators tech enums incompatibilities loses reimplement readme reorganize milli
geometries sourceschema destschema generatedcolumn alphanumerically usages geometries sourceschema destschema generatedcolumn alphanumerically usages
sizable instantiates renders sdt txcommit unhelpful optimiser treats rejects referring untrusted computes vacate inverted sizable instantiates renders sdt txcommit unhelpful optimiser treats rejects referring untrusted computes vacate inverted
reordered colliding evgenij archaic invocations apostrophe hypothetically testref ryazanov useless completes highlighting tends degrade
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论