diff --git a/jOOQ/src/main/java/org/jooq/impl/LoaderImpl.java b/jOOQ/src/main/java/org/jooq/impl/LoaderImpl.java index 7b5d88fb5f..cd902bf1a6 100644 --- a/jOOQ/src/main/java/org/jooq/impl/LoaderImpl.java +++ b/jOOQ/src/main/java/org/jooq/impl/LoaderImpl.java @@ -63,7 +63,6 @@ import java.util.stream.Stream; import javax.xml.bind.DatatypeConverter; import org.jooq.BatchBindStep; -import org.jooq.Condition; import org.jooq.Configuration; import org.jooq.DSLContext; import org.jooq.Field; @@ -665,12 +664,12 @@ final class LoaderImpl implements return this; } - private void checkFlags() { + private final void checkFlags() { if (bulk != BULK_NONE && onDuplicate != ON_DUPLICATE_KEY_ERROR) throw new LoaderConfigurationException("Cannot apply bulk loading with onDuplicateKey flags. Turn off either flag."); } - private void executeJSON() throws IOException { + private final void executeJSON() throws IOException { Reader reader = null; try { @@ -721,7 +720,7 @@ final class LoaderImpl implements } } - private void executeRows() { + private final void executeRows() { try { executeSQL(arrays); } @@ -733,7 +732,7 @@ final class LoaderImpl implements } } - private void executeSQL(Iterator iterator) throws SQLException { + private final void executeSQL(Iterator iterator) throws SQLException { Object[] row = null; BatchBindStep bind = null; InsertQuery insert = null; @@ -915,7 +914,7 @@ final class LoaderImpl implements } } - private void commit() throws SQLException { + private final void commit() throws SQLException { Connection connection = configuration.connectionProvider().acquire(); try { @@ -926,7 +925,7 @@ final class LoaderImpl implements } } - private void rollback() throws SQLException { + private final void rollback() throws SQLException { Connection connection = configuration.connectionProvider().acquire(); try { @@ -940,24 +939,17 @@ final class LoaderImpl implements /** * Type-safety... */ - private void addValue0(InsertQuery insert, Field field, Object row) { + private final void addValue0(InsertQuery insert, Field field, Object row) { insert.addValue(field, field.getDataType().convert(row)); } /** * Type-safety... */ - private void addValueForUpdate0(InsertQuery insert, Field field, Object row) { + private final void addValueForUpdate0(InsertQuery insert, Field field, Object row) { insert.addValueForUpdate(field, field.getDataType().convert(row)); } - /** - * Get a type-safe condition - */ - private Condition getCondition(Field field, Object string) { - return field.equal(field.getDataType().convert(string)); - } - // ------------------------------------------------------------------------- // Outcome // -------------------------------------------------------------------------