0

在尝试对大型分隔文本文件进行数据处理时，我决定使用数据库系统来完成这项工作，并提高速度。我需要我开发的程序来完成 6 个关键过程，以完成预期的目标。

  1. 即时创建本地数据库
  2. 创建一个包含未知数量的列或类型的表
  3. 将分隔文件导入表格（根据需要重复 2 和 3）
  4. 执行 SQL 查询以获取所需的记录
  5. 将结果导出到另一个分隔的文本文件

我决定使用 Apache 的 Derby 数据库系统，因为它能够做 1 并且承诺能够做其他 4。

我创建数据库：

    String connectionName = "jdbc:derby:" + databaseName;

    if (createDatabase) {
        connectionName += ";create=true";
    }
    Class.forName("org.apache.derby.jdbc.ClientDriver").newInstance();
    connectionToDatabase = DriverManager.getConnection(connectionName);

这可行，然后我从文件中获取第一条记录并获取字段数量以了解需要多少列：

    String statement = "CREATE TABLE " + tableName + " (";
    for (int i = 1; i <= tableAmount; i++) {
        statement += (char) (64 + i) + " VARCHAR(100)";
        if (i != tableAmount) {
            statement += ",";
        }
    }
    PreparedStatement pstmt = connectionToDatabase.prepareStatement(statement + ")");
    pstmt.executeUpdate();
    connectionToDatabase.commit();

这将按我选择的名称创建一个表（我尝试简单地创建一个名为“HELLO”的表）然后我尝试将文件导入到我创建的表中：

    try {

        String schemaName = "APP";
        String tableName = "HELLO";
        String fileName = "C:\\Hello.txt";
        String columnDelimiter = fieldDelimiter;
        String characterDelimiter = "";
        String codeset = "UTF-8";
        short replace = 0;

        Import.importTable(connectionToDatabase, schemaName, tableName, fileName,
                columnDelimiter, characterDelimiter, codeset,
                replace, false);
    } catch (SQLException e) {
        do {
            System.out.println("SQLState:" + e.getSQLState());
            System.out.println("Error Code:" + e.getErrorCode());
            System.out.println("Message:" + e.getMessage());
            Throwable t = e.getCause();
            while (t != null) {
                System.out.println("Cause:" + t);
                t = t.getCause();
            }
            e = e.getNextException();
            StackTraceElement st[] = e.getStackTrace();

            for (int i = 0; i < st.length; i++) {
                System.out.println("Stack Trace " + i + ":" + st[i]);
            }
        } while (e != null);
    }catch (Exception e) {
        System.err.println("Exception: " + e.getMessage());

    }

但是当我运行它时，我得到的是：

Exception: Syntax error: DERBY-PROPERTIES

我做错了什么，如果可能的话，我应该怎么做才能完成这项工作？

编辑：它在调用 Import.importTable 的行上出错。在修改我的错误输出后（上图），我现在得到以下输出：

SQLState:42X01
Error Code:30000
Message:Syntax error: DERBY-PROPERTIES.
Cause:java.sql.SQLException: Syntax error: DERBY-PROPERTIES.
Cause:ERROR 42X01: Syntax error: DERBY-PROPERTIES.
Stack Trace 0:org.apache.derby.impl.jdbc.SQLExceptionFactory40.getSQLException(Unknown Source)
Stack Trace 1:org.apache.derby.impl.jdbc.Util.generateCsSQLException(Unknown Source)
Stack Trace 2:org.apache.derby.impl.jdbc.TransactionResourceImpl.wrapInSQLException(Unknown Source)
Stack Trace 3:org.apache.derby.impl.jdbc.TransactionResourceImpl.handleException(Unknown Source)
Stack Trace 4:org.apache.derby.impl.jdbc.EmbedConnection.handleException(Unknown Source)
Stack Trace 5:org.apache.derby.impl.jdbc.ConnectionChild.handleException(Unknown Source)
Stack Trace 6:org.apache.derby.impl.jdbc.EmbedPreparedStatement.<init>(Unknown Source)
Stack Trace 7:org.apache.derby.impl.jdbc.EmbedPreparedStatement20.<init>(Unknown Source)
Stack Trace 8:org.apache.derby.impl.jdbc.EmbedPreparedStatement30.<init>(Unknown Source)
Stack Trace 9:org.apache.derby.impl.jdbc.EmbedPreparedStatement40.<init>(Unknown Source)
Stack Trace 10:org.apache.derby.jdbc.Driver40.newEmbedPreparedStatement(Unknown Source)
Stack Trace 11:org.apache.derby.impl.jdbc.EmbedConnection.prepareStatement(Unknown Source)
Stack Trace 12:org.apache.derby.impl.jdbc.EmbedConnection.prepareStatement(Unknown Source)
Stack Trace 13:org.apache.derby.impl.load.Import.performImport(Unknown Source)
Stack Trace 14:org.apache.derby.impl.load.Import.importTable(Unknown Source)
Stack Trace 15:root.DatabaseManager.<init>(DatabaseManager.java:46)
Stack Trace 16:root.Startup.main(Startup.java:21)

以下是我的 derby.log 的输出

Wed Nov 14 20:04:23 CST 2012:
Booting Derby version The Apache Software Foundation - Apache Derby - 10.9.1.0 - (1344872): instance a816c00e-013b-01cf-55d8-000000c58148 on database directory -omitted-  with class loader sun.misc.Launcher$AppClassLoader@1ba34f2 Loaded from file:/-omitted-/lib/derby.jar java.vendor=Sun Microsystems Inc. java.runtime.version=1.6.0_33-b05 user.dir=-omitted-
derby.system.home=null
Database Class Loader started - derby.database.classpath=''

找出了问题：

  • 我使用了错误的驱动程序：我使用的是客户端驱动程序而不是嵌入式驱动程序

  • 我使用了不正确的功能。它可以进行一些编辑，但正确的是

    Statement s = connectionToDatabase.createStatement();
s.execute("CALL SYSCS_UTIL.SYSCS_IMPORT_TABLE(null,'" + tableName
        + "','" + filePath + "','" + columnDelimiter
        + "',null,null,1)");
connectionToDatabase.commit();
  • 最后，最后一个问题是我使用的文本文件的最后一行没有下一行。
4

1 回答 1

0

首先，您可以从异常中获取更多信息；方法如下：http ://wiki.apache.org/db-derby/UnwindExceptionChain

其次，您应该在磁盘上找到您的“derby.log”文件；它将有更多关于出了什么问题的信息。

第三，一旦您弄清楚了您向数据库发出的确切语句，以及您在代码中的哪个位置发出了该语句，请使用该信息更新您的问题，我们可以提供更多帮助。

于 2012-11-14T14:53:42.060 回答