Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
1.99.4
-
None
Description
Examples:
private void insertConnectorDirection(Long connectorId, Direction direction, Connection conn) throws SQLException { PreparedStatement stmt = null; try { stmt = conn.prepareStatement(CommonRepositoryInsertUpdateDeleteSelectQuery.STMT_INSERT_SQ_CONNECTOR_DIRECTIONS); stmt.setLong(1, connectorId); stmt.setLong(2, getDirection(direction, conn)); if (stmt.executeUpdate() != 1) { throw new SqoopException(CommonRepositoryError.COMMON_0043); } } finally { closeStatements(stmt); } } private void insertConnectorDirections(Long connectorId, SupportedDirections directions, Connection conn) throws SQLException { if (directions.isDirectionSupported(Direction.FROM)) { insertConnectorDirection(connectorId, Direction.FROM, conn); } if (directions.isDirectionSupported(Direction.TO)) { insertConnectorDirection(connectorId, Direction.TO, conn); } }
Attachments
Issue Links
- depends upon
-
SQOOP-1589 Sqoop2: Create common constants, error codes, and queries
- Resolved
- relates to
-
SQOOP-1680 DOC: Create an Public API doc for the Sqoop repository.
- Resolved