diff --git a/symmetric-client/src/main/java/org/jumpmind/symmetric/io/AbstractBulkDatabaseWriter.java b/symmetric-client/src/main/java/org/jumpmind/symmetric/io/AbstractBulkDatabaseWriter.java index ccb5c7b671..84d906350e 100644 --- a/symmetric-client/src/main/java/org/jumpmind/symmetric/io/AbstractBulkDatabaseWriter.java +++ b/symmetric-client/src/main/java/org/jumpmind/symmetric/io/AbstractBulkDatabaseWriter.java @@ -1,8 +1,26 @@ +/** + * Licensed to JumpMind Inc under one or more contributor + * license agreements. See the NOTICE file distributed + * with this work for additional information regarding + * copyright ownership. JumpMind Inc licenses this file + * to you under the GNU General Public License, version 3.0 (GPLv3) + * (the "License"); you may not use this file except in compliance + * with the License. + * + * You should have received a copy of the GNU General Public License, + * version 3.0 (GPLv3) along with this library; if not, see + * . + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ package org.jumpmind.symmetric.io; import org.jumpmind.db.platform.IDatabasePlatform; -import org.jumpmind.db.sql.JdbcSqlTemplate; -import org.jumpmind.db.sql.JdbcSqlTransaction; import org.jumpmind.symmetric.common.ContextConstants; import org.jumpmind.symmetric.io.data.Batch; import org.jumpmind.symmetric.io.data.CsvData; @@ -26,7 +44,7 @@ public void start(Batch batch) { if (isFallBackToDefault()) { getTransaction().setInBatchMode(false); log.debug("Writing batch " + batch.getBatchId() + " on channel " + batch.getChannelId() + " to node " + batch.getTargetNodeId() + " using DEFAULT loader"); - }else{ + } else { log.debug("Writing batch " + batch.getBatchId() + " on channel " + batch.getChannelId() + " to node " + batch.getTargetNodeId() + " using BULK loader"); } } @@ -34,7 +52,7 @@ public void start(Batch batch) { public final void write(CsvData data) { if (isFallBackToDefault()) { writeDefault(data); - }else{ + } else { context.put(ContextConstants.CONTEXT_BULK_WRITER_TO_USE, "bulk"); bulkWrite(data); }