| | |
| | | try { |
| | | rs = connection.getMetaData().getTables(null, _pgSchema, tableName, new String[]{"TABLE"}); |
| | | if (rs.next()) { |
| | | stmt.execute("DROP TABLE " + encodeSchemaTableName(_pgSchema, tableName) + "CASCADE"); |
| | | stmt.execute("DROP TABLE " + encodeSchemaTableName(_pgSchema, tableName) + " CASCADE"); |
| | | } |
| | | |
| | | stmt.executeUpdate("CREATE TABLE " + encodeSchemaTableName(_pgSchema, tableName) + " " + sql); |
| | |
| | | try { |
| | | rs = connection.getMetaData().getTables(null, null, tableName, new String[]{"TABLE"}); |
| | | if (rs.next()) { |
| | | stmt.execute("DROP TABLE " + encodeSchemaTableName(null, tableName) + "CASCADE"); |
| | | stmt.execute("DROP TABLE " + encodeSchemaTableName(null, tableName) + " CASCADE"); |
| | | } |
| | | |
| | | stmt.executeUpdate("CREATE TEMP TABLE " + encodeSchemaTableName(null, tableName) + " " + sql); |
| | |
| | | // stmt.execute("SELECT * INTO " + tableName + " FROM " + tempTable); |
| | | stmt.execute("INSERT INTO " + tableName + " SELECT * FROM " + tempTable); |
| | | } |
| | | stmt.execute("DROP TABLE " + tempTable); |
| | | stmt.execute("DROP TABLE " + tempTable + " CASCADE"); |
| | | } finally { |
| | | JDBCUtils.close(rs); |
| | | JDBCUtils.close(stmt); |