Single class to illustrate loading data…<\/p>\n
\r\nimport java.sql.*;\r\nimport java.util.*;\r\n\r\npublic class loadSnowflake {\r\n public static void main(String[] args) throws Exception {\r\n Class.forName(\"oracle.jdbc.driver.OracleDriver\");\r\n Class.forName(\"com.snowflake.client.jdbc.SnowflakeDriver\");\r\n Properties properties = new Properties();\r\n properties.put(\"user\", \"showard\");\r\n properties.put(\"password\", \"*****\");\r\n properties.put(\"account\", \"rcaccount#\");\r\n properties.put(\"schema\", \"PUBLIC\");\r\n Connection connection = DriverManager.getConnection(\"jdbc:snowflake:\/\/rcaccount#.us-east-1.snowflakecomputing.com?db=SDHPOC\", properties);\r\n Connection connOra = DriverManager.getConnection(\"jdbc:oracle:thin:showard\/****@orahost:1521\/service.domain\");\r\n ResultSet rst = connOra.createStatement().executeQuery(\"select * from sa_tran_head where tran_datetime > sysdate - 7 and rownum <= 1000\");\r\n ResultSetMetaData rsmd = rst.getMetaData();\r\n PreparedStatement snowflakePst = connection.prepareStatement(\"insert into snowflake_sa_tran_head values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,\r\n ?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)\");\r\n int i = 0;\r\n while (rst.next()) {\r\n for (int j = 1; j <= rsmd.getColumnCount(); j++) {\r\n\tif (rsmd.getColumnTypeName(j).equals(\"NUMBER\")) {\r\n snowflakePst.setLong(j,rst.getLong(j));\r\n\t}\r\n\telse if (rsmd.getColumnTypeName(j).equals(\"DATE\")) {\r\n snowflakePst.setDate(j,rst.getDate(j));\r\n\t}\r\n\tif (rsmd.getColumnTypeName(j).equals(\"VARCHAR2\")) {\r\n snowflakePst.setString(j,rst.getString(j));\r\n\t}\r\n }\r\n snowflakePst.addBatch();\r\n if (++i % 1000 == 0) {\r\n System.out.println(\"Starting to execute batch (\" + i + \") at \" + new java.util.Date());\r\n \tsnowflakePst.executeBatch();\r\n\tconnection.commit();\r\n System.out.println(\"Finished batch (\" + i + \") at \" + new java.util.Date());\r\n }\r\n }\r\n try {\r\n snowflakePst.executeBatch();\r\n }\r\n catch (Exception e) {\r\n System.out.println(e.getMessage());\r\n }\r\n connection.commit();\r\n connection.createStatement().execute(\"truncate table if exists snowflake_sa_tran_head\");\r\n System.out.println(\"loaded then truncated data\");\r\n \/\/too lazy to close, doesn't really matter since JVM is exiting...\r\n }\r\n}\r\n<\/pre>\n","protected":false},"excerpt":{"rendered":"Single class to illustrate loading data… import java.sql.*; import java.util.*; public class loadSnowflake { public static void main(String[] args) throws Exception { Class.forName(“oracle.jdbc.driver.OracleDriver”); Class.forName(“com.snowflake.client.jdbc.SnowflakeDriver”); Properties properties = new Properties(); properties.put(“user”, “showard”); properties.put(“password”, “*****”); properties.put(“account”, “rcaccount#”); properties.put(“schema”, “PUBLIC”); Connection connection =…<\/p>\n