我无法使用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();
。