如何为setAsciiStream方法提供正确的参数？

Question

这是我的完整测试代码，主要方法如下：

public class TestSetAscii {

    public static void main(String[] args) throws SQLException, FileNotFoundException {
        String dataFile = "FastLoad1.csv";
        String insertTable = "INSERT INTO " + "myTableName" + " VALUES(?,?,?)";
        Connection conStd = DriverManager.getConnection("jdbc:xxxxx", "xxxxxx", "xxxxx");
        InputStream dataStream = new FileInputStream(new File(dataFile));
        PreparedStatement pstmtFld  = conStd.prepareStatement(insertTable);
            // Until this line everything is awesome

        pstmtFld.setAsciiStream(1, dataStream, -1); // This line fails
        System.out.println("works");
    }
}

我得到了"cbColDef值超出范围“错误。

Exception in thread "main" java.sql.SQLException: [Teradata][ODBC Teradata Driver] Invalid precision: cbColDef value out of range
    at sun.jdbc.odbc.JdbcOdbc.createSQLException(Unknown Source)
    at sun.jdbc.odbc.JdbcOdbc.standardError(Unknown Source)
    at sun.jdbc.odbc.JdbcOdbc.SQLBindInParameterAtExec(Unknown Source)
    at sun.jdbc.odbc.JdbcOdbcPreparedStatement.setStream(Unknown Source)
    at sun.jdbc.odbc.JdbcOdbcPreparedStatement.setAsciiStream(Unknown Source)
    at file.TestSetAscii.main(TestSetAscii.java:21)

这是指向我的FastLoad1.csv文件的链接。我想setAsciiStream失败是因为FastLoad1.csv文件，但我不确定

(在我以前的https://stackoverflow.com/questions/20169127/what-is-illegalstateexception?noredirect=1#comment30067341_20169127中，我无法缩小我所遇到的问题。现在我缩短了代码。)

Answer 1

它将依赖于表模式，但是setAsciiStream的第三个参数是length。所以

pstmtFld.setAsciiStream(1, dataStream, 4);  

将适用于长度为4字节的字段。

但我认为它不会像你在代码中所期望的那样起作用。对于每个绑定，您应该有单独的流。

此函数setAsciiStream()设计用于大数据值BLOBS或长VARCHARS。它不适合逐行读取csv文件，并将它们拆分为单独的值。

基本上，它只是将其中一个问号与inputStream绑定在一起。

在查看了所提供的示例之后，看起来teradata可以处理csv，但是您必须使用以下方法显式地告诉它：

String urlFld = "jdbc:teradata://whomooz/TMODE=ANSI,CHARSET=UTF8,TYPE=FASTLOADCSV";  

Answer 2

我没有足够的声誉来评论，但我觉得这个信息对于那些第一次通过JDBC导航快速加载的人来说是很有价值的。

这段代码将得到完整的堆栈跟踪，对于诊断快速加载的问题非常有帮助：

catch (SQLException ex){
    for ( ; ex != null ; ex = ex.getNextException ())
        ex.printStackTrace () ;
}

在上面的代码中，如果您在连接字符串中指定了TYPE=FASTLOADCSV，但是当多次运行由于创建了错误表_ERR_1和_ERR_2而失败时，它就会工作。删除这些表并清除目标表以再次运行。