无法通过Java执行Snowflake COPY命令



我无法使用java从SnowFlake上的阶段加载数据。

我没有看到任何错误,但数据没有从阶段"加载";mystage";到表";TESTTABLE";代码:

Connection connection =  DriverManager.getConnection(connectionUrl, _connectionProperties);
Statement statement = connection.createStatement();
statement.executeQuery("copy into TESTTABLE (id, name) from (select $1, $2 from @mystage/F.csv.gz t);");

若我在SnowFlake控制台中运行相同的命令,数据就会被加载到表"中;TESTTABLE";正确地

我们不知道默认连接指向哪个数据库/架构。我会尝试使用完全限定的表名:

statement.executeQuery("copy into <db_name>.<schema_name>.TESTTABLE (id, name) from (select $1, $2 from @mystage/F.csv.gz t);");

我错误地注释出了问题所在的connection.commit();

最新更新