import org.h2.tools.DeleteDbFiles; //导入依赖的package包/类
private void testSplitDatabaseInZip() throws SQLException {
    String dir = getBaseDir() + "/fs";
    FileUtils.deleteRecursive(dir, false);
    Connection conn;
    Statement stat;
    conn = getConnection("jdbc:h2:split:18:"+dir+"/test");
    stat = conn.createStatement();
    stat.execute(
            "create table test(id int primary key, name varchar) " +
            "as select x, space(10000) from system_range(1, 100)");
    // stat.execute("shutdown defrag");
    conn.close();
    Backup.execute(dir + "/test.zip", dir, "", true);
    DeleteDbFiles.execute("split:" + dir, "test", true);
    conn = getConnection(
            "jdbc:h2:split:zip:"+dir+"/test.zip!/test");
    conn.createStatement().execute("select * from test where id=1");
    conn.close();
    FileUtils.deleteRecursive(dir, false);
}
 

import org.h2.tools.DeleteDbFiles; //导入依赖的package包/类
/** Prepares Db and data source, which must be added to Camel registry. */
@BeforeClass
public static void setup() throws Exception {
    DeleteDbFiles.execute("~", "jbpm-db-test", true);

    h2Server = Server.createTcpServer(new String[0]);
    h2Server.start();

    setupDb();

    DataSource ds = setupDataSource();

    SimpleRegistry simpleRegistry = new SimpleRegistry();
    simpleRegistry.put("myDs", ds);

    handler = new CamelHandler(new SQLURIMapper(), new RequestPayloadMapper("payload"), new ResponsePayloadMapper("queryResult"), new DefaultCamelContext(simpleRegistry));
}
 

import org.h2.tools.DeleteDbFiles; //导入依赖的package包/类
private static void test() throws SQLException {
    DeleteDbFiles.execute("data", "test", true);
    Connection conn = DriverManager.getConnection("jdbc:h2:data/test");
    Statement stat = conn.createStatement();
    stat.execute("create table test1(id identity, name varchar)");
    stat.execute("create table test2(id identity, name varchar)");
    conn.setAutoCommit(true);
    // use two tables to make sure the data stored on disk is not too simple
    PreparedStatement prep1 = conn.prepareStatement(
            "insert into test1(name) values(space(255))");
    PreparedStatement prep2 = conn.prepareStatement(
            "insert into test2(name) values(space(255))");
    for (int i = 0; i < 50000; i++) {
        if (i % 7 != 0) {
            prep1.execute();
        } else {
            prep2.execute();
        }
    }
    Profiler prof = new Profiler();
    prof.startCollecting();
    stat.execute("DROP TABLE test1");
    prof.stopCollecting();
    System.out.println(prof.getTop(3));
    conn.close();
}
 

import org.h2.tools.DeleteDbFiles; //导入依赖的package包/类
/**
 * Run just this test.
 *
 * @param args ignored
 */
public static void main(String... args) throws Exception {
    DeleteDbFiles.execute("data", null, true);
    Class.forName("org.h2.Driver");
    Connection conn;
    conn = DriverManager.getConnection("jdbc:h2:data/test");
    Statement stat = conn.createStatement();
    stat.execute("create table test(id int primary key, name varchar)");
    stat.execute("insert into test values(1, 'Hello')");
    stat.execute("insert into test values(2, 'World')");
    stat.execute("create linked table test_link" +
            "('', 'jdbc:h2:data/test', '', '', 'TEST')");
    stat.execute("set trace_level_system_out 2");
    // the query sent to the linked database is
    // SELECT * FROM PUBLIC.TEST T WHERE ID>=? AND ID<=? {1: 1, 2: 1};
    // it should also include AND NAME='Hello'
    stat.execute("select * from test_link " +
            "where id = 1 and name = 'Hello'");
    conn.close();
}
 

import org.h2.tools.DeleteDbFiles; //导入依赖的package包/类
private static void test() throws SQLException {
    DeleteDbFiles.execute("data", "test", true);
    Connection conn = DriverManager.getConnection("jdbc:h2:data/test");
    Statement stat = conn.createStatement();
    stat.execute("set max_operation_memory 100");
    stat.execute("set max_memory_undo 100");
    stat.execute("create table test(id identity, name varchar)");
    conn.setAutoCommit(false);
    PreparedStatement prep = conn.prepareStatement(
            "insert into test(name) values(space(1024*1024))");
    long time = System.currentTimeMillis();
    for (int i = 0; i < 2500; i++) {
        prep.execute();
        long now = System.currentTimeMillis();
        if (now > time + 5000) {
            System.out.println(i);
            time = now + 5000;
        }
    }
    conn.rollback();
    conn.close();
}
 

import org.h2.tools.DeleteDbFiles; //导入依赖的package包/类
private void testRecoverClob() throws Exception {
    DeleteDbFiles.execute(getBaseDir(), "recovery", true);
    Connection conn = getConnection("recovery");
    Statement stat = conn.createStatement();
    stat.execute("create table test(id int, data clob)");
    stat.execute("insert into test values(1, space(100000))");
    conn.close();
    Recover.main("-dir", getBaseDir(), "-db", "recovery");
    DeleteDbFiles.execute(getBaseDir(), "recovery", true);
    conn = getConnection(
            "recovery;init=runscript from '" +
            getBaseDir() + "/recovery.h2.sql'");
    stat = conn.createStatement();
    stat.execute("select * from test");
    conn.close();
}
 

import org.h2.tools.DeleteDbFiles; //导入依赖的package包/类
private void testRecoverFulltext() throws Exception {
    DeleteDbFiles.execute(getBaseDir(), "recovery", true);
    Connection conn = getConnection("recovery");
    Statement stat = conn.createStatement();
    stat.execute("CREATE ALIAS IF NOT EXISTS FTL_INIT " +
            "FOR \"org.h2.fulltext.FullTextLucene.init\"");
    stat.execute("CALL FTL_INIT()");
    stat.execute("create table test(id int primary key, name varchar) as " +
            "select 1, 'Hello'");
    stat.execute("CALL FTL_CREATE_INDEX('PUBLIC', 'TEST', 'NAME')");
    conn.close();
    Recover.main("-dir", getBaseDir(), "-db", "recovery");
    DeleteDbFiles.execute(getBaseDir(), "recovery", true);
    conn = getConnection(
            "recovery;init=runscript from '" +
            getBaseDir() + "/recovery.h2.sql'");
    conn.close();
}
 

import org.h2.tools.DeleteDbFiles; //导入依赖的package包/类
private void testDeleteFiles() throws SQLException {
    deleteDb("testDeleteFiles");
    Connection conn = getConnection("testDeleteFiles");
    Statement stat = conn.createStatement();
    stat.execute("create table test(c clob) as select space(10000) from dual");
    conn.close();
    // the name starts with the same string, but does not match it
    DeleteDbFiles.execute(getBaseDir(), "testDelete", true);
    conn = getConnection("testDeleteFiles");
    stat = conn.createStatement();
    ResultSet rs;
    rs = stat.executeQuery("select * from test");
    rs.next();
    rs.getString(1);
    conn.close();
    deleteDb("testDeleteFiles");
}
 

import org.h2.tools.DeleteDbFiles; //导入依赖的package包/类
/**
 * This method is called before a complete set of tests is run. It deletes
 * old database files in the test directory and trace files. It also starts
 * a TCP server if the test uses remote connections.
 */
public void beforeTest() throws SQLException {
    Driver.load();
    FileUtils.deleteRecursive(TestBase.BASE_TEST_DIR, true);
    DeleteDbFiles.execute(TestBase.BASE_TEST_DIR, null, true);
    FileUtils.deleteRecursive("trace.db", false);
    if (networked) {
        String[] args = ssl ? new String[] { "-tcpSSL", "-tcpPort", "9192" }
                : new String[] { "-tcpPort", "9192" };
        server = Server.createTcpServer(args);
        try {
            server.start();
        } catch (SQLException e) {
            System.out.println("FAIL: can not start server (may already be running)");
            server = null;
        }
    }
}
 

import org.h2.tools.DeleteDbFiles; //导入依赖的package包/类
/**
 * Called when ran from command line.
 *
 * @param args ignored
 */
public static void main(String... args) throws Exception {
    // delete the database named 'test' in the user home directory
    DeleteDbFiles.execute("~", "test", true);

    Class.forName("org.h2.Driver");
    Connection conn = DriverManager.getConnection("jdbc:h2:~/test");
    Statement stat = conn.createStatement();

    // this line would initialize the database
    // from the SQL script file 'init.sql'
    // stat.execute("runscript from 'init.sql'");

    stat.execute("create table test(id int primary key, name varchar(255))");
    stat.execute("insert into test values(1, 'Hello')");
    ResultSet rs;
    rs = stat.executeQuery("select * from test");
    while (rs.next()) {
        System.out.println(rs.getString("name"));
    }
    stat.close();
    conn.close();
}
 

import org.h2.tools.DeleteDbFiles; //导入依赖的package包/类
public static void main(String... args) throws Exception {
    // delete the database named 'test' in the user home directory
    DeleteDbFiles.execute("~", "test", true);

    Class.forName("org.h2.Driver");
    Connection conn = DriverManager.getConnection("jdbc:h2:~/test", "admin", "admin");
    Statement stat = conn.createStatement();

    // this line would initialize the database
    // from the SQL script file 'init.sql'
    // stat.execute("runscript from 'init.sql'");

    stat.execute("create table test(id int primary key, name varchar(255))");
    stat.execute("insert into test values(1, 'Hello')");
    ResultSet rs;
    rs = stat.executeQuery("select * from test");
    while (rs.next()) {
        System.out.println(rs.getString("name"));
    }
    stat.close();
    conn.close();
}
 

import org.h2.tools.DeleteDbFiles; //导入依赖的package包/类
private void testCorrupt() throws Exception {
    if (config.mvStore) {
        // not needed for MV_STORE=TRUE
        return;
    }
    DeleteDbFiles.execute(getBaseDir(), "recovery", true);
    Connection conn = getConnection("recovery");
    Statement stat = conn.createStatement();
    stat.execute("create table test(id int, name varchar) as " +
            "select 1, 'Hello World1'");
    conn.close();
    FileChannel f = FileUtils.open(getBaseDir() + "/recovery.h2.db", "rw");
    byte[] buff = new byte[Constants.DEFAULT_PAGE_SIZE];
    while (f.position() < f.size()) {
        FileUtils.readFully(f, ByteBuffer.wrap(buff));
        if (new String(buff).contains("Hello World1")) {
            buff[buff.length - 1]++;
            f.position(f.position() - buff.length);
            f.write(ByteBuffer.wrap(buff));
        }
    }
    f.close();
    Recover.main("-dir", getBaseDir(), "-db", "recovery");
    String script = IOUtils.readStringAndClose(
            new InputStreamReader(
            FileUtils.newInputStream(getBaseDir() + "/recovery.h2.sql")), -1);
    assertContains(script, "checksum mismatch");
    assertContains(script, "dump:");
    assertContains(script, "Hello World2");
}
 

import org.h2.tools.DeleteDbFiles; //导入依赖的package包/类
private void testCompressedAndUncompressed() throws SQLException {
    DeleteDbFiles.execute(getBaseDir(), "recovery", true);
    DeleteDbFiles.execute(getBaseDir(), "recovery2", true);
    org.h2.Driver.load();
    Connection conn = getConnection("recovery");
    Statement stat = conn.createStatement();
    stat.execute("create table test(id int primary key, data clob)");
    stat.execute("insert into test values(1, space(10000))");
    stat.execute("set compress_lob lzf");
    stat.execute("insert into test values(2, space(10000))");
    conn.close();
    Recover rec = new Recover();
    rec.runTool("-dir", getBaseDir(), "-db", "recovery");
    Connection conn2 = getConnection("recovery2");
    Statement stat2 = conn2.createStatement();
    String name = "recovery.h2.sql";
    stat2.execute("runscript from '" + getBaseDir() + "/" + name + "'");
    stat2.execute("select * from test");
    conn2.close();

    conn = getConnection("recovery");
    stat = conn.createStatement();
    conn2 = getConnection("recovery2");
    stat2 = conn2.createStatement();

    assertEqualDatabases(stat, stat2);
    conn.close();
    conn2.close();
    DeleteDbFiles.execute(getBaseDir(), "recovery", true);
    DeleteDbFiles.execute(getBaseDir(), "recovery2", true);
}
 

import org.h2.tools.DeleteDbFiles; //导入依赖的package包/类
private void testImplicitRelativePath() throws Exception {
    if (SysProperties.IMPLICIT_RELATIVE_PATH) {
        return;
    }
    assertThrows(ErrorCode.URL_RELATIVE_TO_CWD, this).
        getConnection("jdbc:h2:test");
    assertThrows(ErrorCode.URL_RELATIVE_TO_CWD, this).
        getConnection("jdbc:h2:data/test");

    getConnection("jdbc:h2:./testDatabase").close();
    DeleteDbFiles.execute(".", "testDatabase", true);
}
 

import org.h2.tools.DeleteDbFiles; //导入依赖的package包/类
@Override
public void test() throws Exception {
    if (config.networked) {
        return;
    }
    DeleteDbFiles.execute(getBaseDir(), null, true);
    org.h2.Driver.load();
    testSimpleResultSet();
    testTcpServerWithoutPort();
    testConsole();
    testJdbcDriverUtils();
    testWrongServer();
    testDeleteFiles();
    testScriptRunscriptLob();
    testServerMain();
    testRemove();
    testConvertTraceFile();
    testManagementDb();
    testChangeFileEncryption(false);
    if (!config.splitFileSystem) {
        testChangeFileEncryption(true);
    }
    testChangeFileEncryptionWithWrongPassword();
    testServer();
    testScriptRunscript();
    testBackupRestore();
    testRecover();
    FileUtils.delete(getBaseDir() + "/b2.sql");
    FileUtils.delete(getBaseDir() + "/b2.sql.txt");
    FileUtils.delete(getBaseDir() + "/b2.zip");
}
 

import org.h2.tools.DeleteDbFiles; //导入依赖的package包/类
private void testBackupRestore() throws SQLException {
    org.h2.Driver.load();
    String url = "jdbc:h2:" + getBaseDir() + "/testBackupRestore";
    String user = "sa", password = "abc";
    final String fileName = getBaseDir() + "/b2.zip";
    DeleteDbFiles.main("-dir", getBaseDir(), "-db", "testBackupRestore",
            "-quiet");
    Connection conn = getConnection(url, user, password);
    conn.createStatement().execute(
            "CREATE TABLE TEST(ID INT PRIMARY KEY, NAME VARCHAR)");
    conn.createStatement().execute("INSERT INTO TEST VALUES(1, 'Hello')");
    conn.close();
    Backup.main("-file", fileName, "-dir", getBaseDir(), "-db",
            "testBackupRestore", "-quiet");
    DeleteDbFiles.main("-dir", getBaseDir(), "-db", "testBackupRestore",
            "-quiet");
    Restore.main("-file", fileName, "-dir", getBaseDir(), "-db",
            "testBackupRestore", "-quiet");
    conn = getConnection("jdbc:h2:" + getBaseDir() + "/testBackupRestore",
            "sa", "abc");
    ResultSet rs = conn.createStatement()
            .executeQuery("SELECT * FROM TEST");
    assertTrue(rs.next());
    assertFalse(rs.next());
    new AssertThrows(ErrorCode.CANNOT_CHANGE_SETTING_WHEN_OPEN_1) {
        @Override
        public void test() throws SQLException {
            // must fail when the database is in use
            Backup.main("-file", fileName, "-dir", getBaseDir(), "-db",
                    "testBackupRestore");
        }
    };
    conn.close();
    DeleteDbFiles.main("-dir", getBaseDir(), "-db", "testBackupRestore",
            "-quiet");
}
 

import org.h2.tools.DeleteDbFiles; //导入依赖的package包/类
private void testChangeFileEncryption(boolean split) throws SQLException {
    org.h2.Driver.load();
    final String dir = (split ? "split:19:" : "") + getBaseDir();
    String url = "jdbc:h2:" + dir + "/testChangeFileEncryption;CIPHER=AES";
    DeleteDbFiles.execute(dir, "testChangeFileEncryption", true);
    Connection conn = getConnection(url, "sa", "abc 123");
    Statement stat = conn.createStatement();
    stat.execute("CREATE TABLE TEST(ID INT PRIMARY KEY, DATA CLOB) "
            + "AS SELECT X, SPACE(3000) FROM SYSTEM_RANGE(1, 300)");
    conn.close();
    String[] args = { "-dir", dir, "-db", "testChangeFileEncryption",
            "-cipher", "AES", "-decrypt", "abc", "-quiet" };
    ChangeFileEncryption.main(args);
    args = new String[] { "-dir", dir, "-db", "testChangeFileEncryption",
            "-cipher", "AES", "-encrypt", "def", "-quiet" };
    ChangeFileEncryption.main(args);
    conn = getConnection(url, "sa", "def 123");
    stat = conn.createStatement();
    stat.execute("SELECT * FROM TEST");
    new AssertThrows(ErrorCode.CANNOT_CHANGE_SETTING_WHEN_OPEN_1) {
        @Override
        public void test() throws SQLException {
            ChangeFileEncryption.main(new String[] { "-dir", dir, "-db",
                    "testChangeFileEncryption", "-cipher", "AES",
                    "-decrypt", "def", "-quiet" });
        }
    };
    conn.close();
    args = new String[] { "-dir", dir, "-db", "testChangeFileEncryption",
            "-quiet" };
    DeleteDbFiles.main(args);
}
 

import org.h2.tools.DeleteDbFiles; //导入依赖的package包/类
private void testChangeFileEncryptionWithWrongPassword() throws SQLException {
    if (config.mvStore) {
        // the file system encryption abstraction used by the MVStore
        // doesn't detect wrong passwords
        return;
    }
    org.h2.Driver.load();
    final String dir = getBaseDir();
    // TODO: this doesn't seem to work in MVSTORE mode yet
    String url = "jdbc:h2:" + dir + "/testChangeFileEncryption;CIPHER=AES";
    DeleteDbFiles.execute(dir, "testChangeFileEncryption", true);
    Connection conn = getConnection(url, "sa", "abc 123");
    Statement stat = conn.createStatement();
    stat.execute("CREATE TABLE TEST(ID INT PRIMARY KEY, DATA CLOB) "
            + "AS SELECT X, SPACE(3000) FROM SYSTEM_RANGE(1, 300)");
    conn.close();
    // try with wrong password, this used to have a bug where it kept the
    // file handle open
    new AssertThrows(SQLException.class) {
        @Override
        public void test() throws SQLException {
            ChangeFileEncryption.execute(dir, "testChangeFileEncryption",
                    "AES", "wrong".toCharArray(),
                    "def".toCharArray(), true);
        }
    };
    ChangeFileEncryption.execute(dir, "testChangeFileEncryption",
            "AES", "abc".toCharArray(), "def".toCharArray(),
            true);

    conn = getConnection(url, "sa", "def 123");
    stat = conn.createStatement();
    stat.execute("SELECT * FROM TEST");
    conn.close();
    String[] args = new String[] { "-dir", dir, "-db", "testChangeFileEncryption", "-quiet" };
    DeleteDbFiles.main(args);
}
 

import org.h2.tools.DeleteDbFiles; //导入依赖的package包/类
/**
 * Delete all database files for a database.
 *
 * @param dir the directory where the database files are located
 * @param name the database name
 */
protected void deleteDb(String dir, String name) {
    DeleteDbFiles.execute(dir, name, true);
    // ArrayList<String> list;
    // list = FileLister.getDatabaseFiles(baseDir, name, true);
    // if (list.size() >  0) {
    //    System.out.println("Not deleted: " + list);
    // }
}
 

import org.h2.tools.DeleteDbFiles; //导入依赖的package包/类
private void deleteDb() {
    String name = getDatabaseName();
    if (name.startsWith("memFS:")) {
        DeleteDbFiles.execute("memFS:/", name, true);
    } else {
        DeleteDbFiles.execute(getBaseDir() + "/dataRandomSQL", null, true);
        FileUtils.delete(getBaseDir() + "/dataRandomSQL");
    }
}