Skip to content

H
h2database
提交 b7cd026b authored 作者: Noel Grandin's avatar Noel Grandin
浏览文件
操作

remove files accidentally committed

上级 6b8fc09d
隐藏空白字符变更
内嵌 并排
正在显示 包含 0 行增加 和 265 行删除
h2/src/test/org/h2/test/Bug_H2_1.java deleted 100644 → 0
浏览文件 @ 6b8fc09d
package org.h2.test;
import java.math.BigDecimal;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class Bug_H2_1 {
static String dbUrl = "jdbc:h2:nioMemFS:dbbug1;DB_CLOSE_DELAY=-1;MULTI_THREADED=1";
static String user = "sa", pwd = "";
static int threadCount = 100;
public static void main(String args[]) throws InterruptedException, SQLException {
Arte2[] artes = new Arte2[threadCount];
Connection dbConnect;
try {
Class.forName("org.h2.Driver");
dbConnect = DriverManager.getConnection(dbUrl, user, pwd);
DbPreparator2.prepareScheme(dbConnect);
System.out.println("DB scheme prepared");
DbPreparator2.populate(dbConnect);
System.out.println("DB populated");
for (int i = 0; i < threadCount; i++) {
artes[i] = new Arte2(DriverManager.getConnection(dbUrl, user, pwd));
}
System.out.println("ARTEs created");
} catch (ClassNotFoundException | SQLException e) {
System.out.println("DB Connection Failed: " + dbUrl);
e.printStackTrace();
return;
}
ExecutorService threadPool = Executors.newFixedThreadPool(threadCount);
for (int i = 0; i < threadCount; i++) {
threadPool.submit(artes[i]);
}
while (true) {
Thread.sleep(100);
}
}
}
class DbPreparator2 {
public static final int OBJ_CNT = 10000;
private static final String[] SQLs = new String[] { "CREATE TABLE IF NOT EXISTS ACCOUNT ("
+ " ID NUMBER(18,0) not null PRIMARY KEY, BALANCE NUMBER null)" };
public static void prepareScheme(Connection db) throws SQLException {
for (String sql : SQLs) {
db.createStatement().execute(sql);
db.commit();
}
}
public static void populate(Connection db) throws SQLException {
PreparedStatement mergeAcctStmt = db.prepareStatement("MERGE INTO Account(id, balance) key (id) VALUES (?, ?)");
for (int i = 0; i < OBJ_CNT; i++) {
mergeAcctStmt.setLong(1, i);
mergeAcctStmt.setBigDecimal(2, BigDecimal.ZERO);
mergeAcctStmt.addBatch();
}
mergeAcctStmt.executeBatch();
db.commit();
}
}
class Arte2 implements Callable<Integer> {
Connection db;
PreparedStatement updateAcctStmt;
public Arte2(Connection db_) throws SQLException {
db = db_;
db.setAutoCommit(false);
updateAcctStmt = db.prepareStatement("UPDATE account set balance = ? where id = ?");
}
@Override
public Integer call() {
try {
while (true) {
updateAcctStmt.setDouble(1, Math.random());
updateAcctStmt.setLong(2, (int) (Math.random() * DbPreparator2.OBJ_CNT));
updateAcctStmt.execute();
db.commit();
}
} catch (SQLException e) {
System.out.println("DB write error: ");
e.printStackTrace();
System.exit(0);
}
return null;
}
}
h2/src/test/org/h2/test/QueryTest.java deleted 100644 → 0
浏览文件 @ 6b8fc09d
package org.h2.test;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
public class QueryTest {
static String dbUrl = "jdbc:h2:~/db1";
public static void main(String[] args) throws Exception {
Class.forName("org.h2.Driver");
Connection conn = DriverManager.getConnection(dbUrl, "sa", "");
InputStream is = QueryTest.class.getResourceAsStream("query.txt");
java.util.Scanner s = new java.util.Scanner(is).useDelimiter("\\A");
String sql = s.next();
long time1 = System.nanoTime();
conn.prepareStatement(sql);
long time2 = System.nanoTime();
System.out.println("time = " + (time2-time1)/1000/1000);
}
}
h2/src/test/org/h2/test/query.txt deleted 100644 → 0
浏览文件 @ 6b8fc09d
INSERT INTO "DB" ("AC",
"AB",
"AA")
SELECT ROWNUM() "I",
"ID",
?
FROM
(SELECT "ID"
FROM
(SELECT MIN("I") "I",
"ID"
FROM
(SELECT ROWNUM() "I",
"ID"
FROM
(SELECT "ID"
FROM
(SELECT "T"."AA" "ID"
FROM "AE" "T"
INNER JOIN "AE" "T101" ON ("T101"."AA"="T"."AA")
INNER JOIN "CS" "T102" ON ("T102"."AA"="T101"."AD")
INNER JOIN "CP" "T103" ON ("T103"."AA"="T102"."AD")
LEFT JOIN "BG" "T104" ON ("T104"."AA"="T103"."AB")
INNER JOIN "AE" "T105" ON ("T105"."AA"="T101"."AA")
INNER JOIN "AE" "T106" ON ("T106"."AA"="T105"."AA")
LEFT JOIN "EB" "T108" ON ("T108"."AA"="T106"."AA")
LEFT JOIN "DV" "T107" ON ("T107"."AA"="T108"."AB")
LEFT JOIN "EB" "T106A" ON ("T106A"."AA"="T106"."AA")
INNER JOIN "AE" "T109" ON ("T109"."AA"="T105"."AA")
LEFT JOIN "EB" "T112" ON ("T112"."AA"="T109"."AA")
LEFT JOIN "DV" "T110" ON ("T110"."AA"="T112"."AB")
LEFT JOIN "EA" "T111" ON ("T111"."AA"="T110"."AA")
LEFT JOIN "EB" "T109A" ON ("T109A"."AA"="T109"."AA")
LEFT JOIN "EB" "T105A" ON ("T105A"."AA"="T105"."AA")
INNER JOIN "AE" "T113" ON ("T113"."AA"="T101"."AA")
INNER JOIN "AE" "T114" ON ("T114"."AA"="T113"."AA")
LEFT JOIN "EB" "T114A" ON ("T114A"."AA"="T114"."AA")
INNER JOIN "AE" "T122" ON ("T122"."AA"="T113"."AA")
LEFT JOIN "EB" "T122A" ON ("T122A"."AA"="T122"."AA")
INNER JOIN "AE" "T130" ON ("T130"."AA"="T113"."AA")
LEFT JOIN "EB" "T130A" ON ("T130A"."AA"="T130"."AA")
INNER JOIN "AE" "T134" ON ("T134"."AA"="T113"."AA")
LEFT JOIN "EB" "T134A" ON ("T134A"."AA"="T134"."AA")
LEFT JOIN "EB" "T113A" ON ("T113A"."AA"="T113"."AA")
LEFT JOIN "EB" "T101A" ON ("T101A"."AA"="T101"."AA")
WHERE "T101A"."AA" IS NOT NULL
AND "T101A"."AA" IS NOT NULL
AND "T104"."AF"=?
AND "T104"."AH"=?
AND "T104"."AI"=?
AND "T101A"."AA" IS NOT NULL
AND "T101A"."AA" IS NOT NULL
AND "T101"."AN"=?
AND "T101A"."AA" IS NOT NULL
AND (("T105A"."AA" IS NOT NULL
AND (("T106A"."AA" IS NOT NULL
AND "T107"."AA"=?)
OR ("T109A"."AA" IS NOT NULL
AND "T110"."AJ"=?
AND "T111"."AA" IS NOT NULL
AND "T111"."AB"=?)))
OR ("T113A"."AA" IS NOT NULL
AND "T113A"."AA" IS NOT NULL
AND (("T114A"."AA" IS NOT NULL
AND "T114"."AA" IN
(SELECT "T118"."AA" "T118AA"
FROM "AE" "T118"
INNER JOIN "CS" "T117" ON ("T117"."AA"="T118"."AD")
INNER JOIN "AH" "T116" ON ("T116"."AE"="T118"."AA")
INNER JOIN "BQ" "T115" ON ("T115"."AA"="T116"."AF")
WHERE "T115"."AA" IN
(SELECT "T119"."AB" "T119AB"
FROM "DX" "T119"
INNER JOIN "AA" "T121" ON ("T121"."AB"="T119"."AA")
INNER JOIN "DV" "T120" ON ("T120"."AA"="T121"."AC")
WHERE "T120"."AA"=?)
AND "T116"."AI"=?))
OR ("T122A"."AA" IS NOT NULL
AND "T122"."AA" IN
(SELECT "T126"."AA" "T126AA"
FROM "AE" "T126"
INNER JOIN "CS" "T125" ON ("T125"."AA"="T126"."AD")
INNER JOIN "AH" "T124" ON ("T124"."AE"="T126"."AA")
INNER JOIN "DK" "T123" ON ("T123"."AA"="T124"."AG")
WHERE "T123"."AA" IN
(SELECT "T127"."AB" "T127AB"
FROM "DZ" "T127"
INNER JOIN "AA" "T129" ON ("T129"."AB"="T127"."AA")
INNER JOIN "DV" "T128" ON ("T128"."AA"="T129"."AC")
WHERE "T128"."AA"=?)
AND "T124"."AI"=?))
OR ("T130A"."AA" IS NOT NULL
AND "T130"."AA" IN
(SELECT "T132"."AE" "T132AE"
FROM "AH" "T132"
INNER JOIN "AA" "T133" ON ("T133"."AB"="T132"."AH")
INNER JOIN "DV" "T131" ON ("T131"."AA"="T133"."AC")
WHERE "T131"."AA"=?
AND "T132"."AI"=?)))
AND "T113A"."AA" IS NOT NULL
AND NOT ("T134A"."AA" IS NOT NULL
AND "T134A"."AA" IS NOT NULL
AND "T134"."AA" IN
(SELECT "T136"."AE" "T136AE"
FROM "AH" "T136"
INNER JOIN "DV" "T135" ON ("T135"."AA"="T136"."AH")
WHERE "T135"."AA"=?
AND "T136"."AI"=?)
AND "T134A"."AA" IS NOT NULL
AND "T134"."AA" IN
(SELECT "T140"."AA" "T140AA"
FROM "AE" "T140"
INNER JOIN "CS" "T139" ON ("T139"."AA"="T140"."AD")
INNER JOIN "AH" "T138" ON ("T138"."AE"="T140"."AA")
INNER JOIN "BQ" "T137" ON ("T137"."AA"="T138"."AF")
WHERE "T137"."AA" IN
(SELECT "T141"."AB" "T141AB"
FROM "DX" "T141"
INNER JOIN "DV" "T142" ON ("T142"."AA"="T141"."AA")
WHERE "T142"."AA"=?)
AND "T138"."AI"=?)
AND "T134A"."AA" IS NOT NULL
AND "T134"."AA" IN
(SELECT "T146"."AA" "T146AA"
FROM "AE" "T146"
INNER JOIN "CS" "T145" ON ("T145"."AA"="T146"."AD")
INNER JOIN "AH" "T144" ON ("T144"."AE"="T146"."AA")
INNER JOIN "DK" "T143" ON ("T143"."AA"="T144"."AG")
WHERE "T143"."AA" IN
(SELECT "T147"."AB" "T147AB"
FROM "DZ" "T147"
INNER JOIN "DV" "T148" ON ("T148"."AA"="T147"."AA")
WHERE "T148"."AA"=?)
AND "T144"."AI"=?))
AND "T113A"."AA" IS NOT NULL
AND "T113A"."AB" IS NULL))
ORDER BY "T"."AA") "t2") "t3") "t4"
GROUP BY "ID"
ORDER BY "I") "t5") "t7"
Markdown 格式
0% 或
您添加了 0 人 到此讨论。请谨慎行事。
请先完成此评论的编辑！
请 注册 或者 后发表评论