#2829 applied eclipse Code Formatting
This commit is contained in:
Johannes Buehler
parent
6e7f1428ce
commit
9c751d7644
File diff suppressed because it is too large
Load Diff
@ -41,7 +41,146 @@
|
||||
|
||||
package org.jooq.impl;
|
||||
|
||||
import org.jooq.*;
|
||||
import static org.jooq.conf.ParamType.INLINED;
|
||||
import static org.jooq.conf.ParamType.NAMED;
|
||||
import static org.jooq.impl.DSL.field;
|
||||
import static org.jooq.impl.DSL.fieldByName;
|
||||
import static org.jooq.impl.DSL.queryPart;
|
||||
import static org.jooq.impl.DSL.template;
|
||||
import static org.jooq.impl.DSL.trueCondition;
|
||||
import static org.jooq.impl.Utils.list;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.Serializable;
|
||||
import java.io.StringReader;
|
||||
import java.math.BigInteger;
|
||||
import java.sql.Connection;
|
||||
import java.sql.PreparedStatement;
|
||||
import java.sql.ResultSet;
|
||||
import java.sql.ResultSetMetaData;
|
||||
import java.sql.SQLException;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Arrays;
|
||||
import java.util.Collection;
|
||||
import java.util.Collections;
|
||||
import java.util.LinkedList;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
import javax.annotation.Generated;
|
||||
import javax.sql.DataSource;
|
||||
|
||||
import org.jooq.Attachable;
|
||||
import org.jooq.Batch;
|
||||
import org.jooq.BatchBindStep;
|
||||
import org.jooq.BindContext;
|
||||
import org.jooq.Condition;
|
||||
import org.jooq.Configuration;
|
||||
import org.jooq.ConnectionProvider;
|
||||
import org.jooq.Cursor;
|
||||
import org.jooq.DSLContext;
|
||||
import org.jooq.DataType;
|
||||
import org.jooq.DeleteQuery;
|
||||
import org.jooq.DeleteWhereStep;
|
||||
import org.jooq.ExecuteContext;
|
||||
import org.jooq.ExecuteListener;
|
||||
import org.jooq.Field;
|
||||
import org.jooq.InsertQuery;
|
||||
import org.jooq.InsertSetStep;
|
||||
import org.jooq.InsertValuesStep1;
|
||||
import org.jooq.InsertValuesStep10;
|
||||
import org.jooq.InsertValuesStep11;
|
||||
import org.jooq.InsertValuesStep12;
|
||||
import org.jooq.InsertValuesStep13;
|
||||
import org.jooq.InsertValuesStep14;
|
||||
import org.jooq.InsertValuesStep15;
|
||||
import org.jooq.InsertValuesStep16;
|
||||
import org.jooq.InsertValuesStep17;
|
||||
import org.jooq.InsertValuesStep18;
|
||||
import org.jooq.InsertValuesStep19;
|
||||
import org.jooq.InsertValuesStep2;
|
||||
import org.jooq.InsertValuesStep20;
|
||||
import org.jooq.InsertValuesStep21;
|
||||
import org.jooq.InsertValuesStep22;
|
||||
import org.jooq.InsertValuesStep3;
|
||||
import org.jooq.InsertValuesStep4;
|
||||
import org.jooq.InsertValuesStep5;
|
||||
import org.jooq.InsertValuesStep6;
|
||||
import org.jooq.InsertValuesStep7;
|
||||
import org.jooq.InsertValuesStep8;
|
||||
import org.jooq.InsertValuesStep9;
|
||||
import org.jooq.InsertValuesStepN;
|
||||
import org.jooq.LoaderOptionsStep;
|
||||
import org.jooq.MergeKeyStep1;
|
||||
import org.jooq.MergeKeyStep10;
|
||||
import org.jooq.MergeKeyStep11;
|
||||
import org.jooq.MergeKeyStep12;
|
||||
import org.jooq.MergeKeyStep13;
|
||||
import org.jooq.MergeKeyStep14;
|
||||
import org.jooq.MergeKeyStep15;
|
||||
import org.jooq.MergeKeyStep16;
|
||||
import org.jooq.MergeKeyStep17;
|
||||
import org.jooq.MergeKeyStep18;
|
||||
import org.jooq.MergeKeyStep19;
|
||||
import org.jooq.MergeKeyStep2;
|
||||
import org.jooq.MergeKeyStep20;
|
||||
import org.jooq.MergeKeyStep21;
|
||||
import org.jooq.MergeKeyStep22;
|
||||
import org.jooq.MergeKeyStep3;
|
||||
import org.jooq.MergeKeyStep4;
|
||||
import org.jooq.MergeKeyStep5;
|
||||
import org.jooq.MergeKeyStep6;
|
||||
import org.jooq.MergeKeyStep7;
|
||||
import org.jooq.MergeKeyStep8;
|
||||
import org.jooq.MergeKeyStep9;
|
||||
import org.jooq.MergeKeyStepN;
|
||||
import org.jooq.MergeUsingStep;
|
||||
import org.jooq.Meta;
|
||||
import org.jooq.Param;
|
||||
import org.jooq.Query;
|
||||
import org.jooq.QueryPart;
|
||||
import org.jooq.Record;
|
||||
import org.jooq.Record1;
|
||||
import org.jooq.Record10;
|
||||
import org.jooq.Record11;
|
||||
import org.jooq.Record12;
|
||||
import org.jooq.Record13;
|
||||
import org.jooq.Record14;
|
||||
import org.jooq.Record15;
|
||||
import org.jooq.Record16;
|
||||
import org.jooq.Record17;
|
||||
import org.jooq.Record18;
|
||||
import org.jooq.Record19;
|
||||
import org.jooq.Record2;
|
||||
import org.jooq.Record20;
|
||||
import org.jooq.Record21;
|
||||
import org.jooq.Record22;
|
||||
import org.jooq.Record3;
|
||||
import org.jooq.Record4;
|
||||
import org.jooq.Record5;
|
||||
import org.jooq.Record6;
|
||||
import org.jooq.Record7;
|
||||
import org.jooq.Record8;
|
||||
import org.jooq.Record9;
|
||||
import org.jooq.RenderContext;
|
||||
import org.jooq.Result;
|
||||
import org.jooq.ResultQuery;
|
||||
import org.jooq.SQLDialect;
|
||||
import org.jooq.Schema;
|
||||
import org.jooq.Select;
|
||||
import org.jooq.SelectQuery;
|
||||
import org.jooq.SelectSelectStep;
|
||||
import org.jooq.SelectWhereStep;
|
||||
import org.jooq.Sequence;
|
||||
import org.jooq.Table;
|
||||
import org.jooq.TableLike;
|
||||
import org.jooq.TableRecord;
|
||||
import org.jooq.TruncateIdentityStep;
|
||||
import org.jooq.UDT;
|
||||
import org.jooq.UDTRecord;
|
||||
import org.jooq.UpdatableRecord;
|
||||
import org.jooq.UpdateQuery;
|
||||
import org.jooq.UpdateSetFirstStep;
|
||||
import org.jooq.conf.Settings;
|
||||
import org.jooq.exception.DataAccessException;
|
||||
import org.jooq.exception.InvalidResultException;
|
||||
@ -50,20 +189,6 @@ import org.jooq.impl.BatchCRUD.Action;
|
||||
import org.jooq.tools.csv.CSVReader;
|
||||
import org.jooq.tools.json.JSONReader;
|
||||
|
||||
import javax.annotation.Generated;
|
||||
import javax.sql.DataSource;
|
||||
import java.io.IOException;
|
||||
import java.io.Serializable;
|
||||
import java.io.StringReader;
|
||||
import java.math.BigInteger;
|
||||
import java.sql.*;
|
||||
import java.util.*;
|
||||
|
||||
import static org.jooq.conf.ParamType.INLINED;
|
||||
import static org.jooq.conf.ParamType.NAMED;
|
||||
import static org.jooq.impl.DSL.*;
|
||||
import static org.jooq.impl.Utils.list;
|
||||
|
||||
/**
|
||||
* A default implementation for {@link DSLContext}.
|
||||
* <p>
|
||||
@ -627,7 +752,7 @@ public class DefaultDSLContext implements DSLContext, Serializable {
|
||||
return result;
|
||||
}
|
||||
|
||||
// [jooq-tools] START [select]
|
||||
// [jooq-tools] START [select]
|
||||
|
||||
@Generated("This method was generated using jOOQ-tools")
|
||||
@Override
|
||||
@ -761,7 +886,7 @@ public class DefaultDSLContext implements DSLContext, Serializable {
|
||||
return (SelectSelectStep) select(new Field[] { field1, field2, field3, field4, field5, field6, field7, field8, field9, field10, field11, field12, field13, field14, field15, field16, field17, field18, field19, field20, field21, field22 });
|
||||
}
|
||||
|
||||
// [jooq-tools] END [select]
|
||||
// [jooq-tools] END [select]
|
||||
|
||||
@Override
|
||||
public SelectSelectStep<Record> selectDistinct(Collection<? extends Field<?>> fields) {
|
||||
@ -777,7 +902,7 @@ public class DefaultDSLContext implements DSLContext, Serializable {
|
||||
return result;
|
||||
}
|
||||
|
||||
// [jooq-tools] START [selectDistinct]
|
||||
// [jooq-tools] START [selectDistinct]
|
||||
|
||||
@Generated("This method was generated using jOOQ-tools")
|
||||
@Override
|
||||
@ -911,7 +1036,7 @@ public class DefaultDSLContext implements DSLContext, Serializable {
|
||||
return (SelectSelectStep) selectDistinct(new Field[] { field1, field2, field3, field4, field5, field6, field7, field8, field9, field10, field11, field12, field13, field14, field15, field16, field17, field18, field19, field20, field21, field22 });
|
||||
}
|
||||
|
||||
// [jooq-tools] END [selectDistinct]
|
||||
// [jooq-tools] END [selectDistinct]
|
||||
|
||||
@Override
|
||||
public SelectSelectStep<Record1<Integer>> selectZero() {
|
||||
@ -954,7 +1079,7 @@ public class DefaultDSLContext implements DSLContext, Serializable {
|
||||
return new InsertImpl(configuration, into, Collections.<Field<?>>emptyList());
|
||||
}
|
||||
|
||||
// [jooq-tools] START [insert]
|
||||
// [jooq-tools] START [insert]
|
||||
|
||||
@Generated("This method was generated using jOOQ-tools")
|
||||
@Override
|
||||
@ -1088,7 +1213,7 @@ public class DefaultDSLContext implements DSLContext, Serializable {
|
||||
return new InsertImpl(configuration, into, Arrays.asList(new Field[] { field1, field2, field3, field4, field5, field6, field7, field8, field9, field10, field11, field12, field13, field14, field15, field16, field17, field18, field19, field20, field21, field22 }));
|
||||
}
|
||||
|
||||
// [jooq-tools] END [insert]
|
||||
// [jooq-tools] END [insert]
|
||||
|
||||
@Override
|
||||
public <R extends Record> InsertValuesStepN<R> insertInto(Table<R> into, Field<?>... fields) {
|
||||
@ -1115,7 +1240,7 @@ public class DefaultDSLContext implements DSLContext, Serializable {
|
||||
return new MergeImpl(configuration, table);
|
||||
}
|
||||
|
||||
// [jooq-tools] START [merge]
|
||||
// [jooq-tools] START [merge]
|
||||
|
||||
@Generated("This method was generated using jOOQ-tools")
|
||||
@Override
|
||||
@ -1249,7 +1374,7 @@ public class DefaultDSLContext implements DSLContext, Serializable {
|
||||
return new MergeImpl(configuration, table, Arrays.asList(field1, field2, field3, field4, field5, field6, field7, field8, field9, field10, field11, field12, field13, field14, field15, field16, field17, field18, field19, field20, field21, field22));
|
||||
}
|
||||
|
||||
// [jooq-tools] END [merge]
|
||||
// [jooq-tools] END [merge]
|
||||
|
||||
@Override
|
||||
public <R extends Record> MergeKeyStepN<R> mergeInto(Table<R> table, Field<?>... fields) {
|
||||
@ -1570,7 +1695,7 @@ public class DefaultDSLContext implements DSLContext, Serializable {
|
||||
return (Record22) newRecord(new Field[] { field1, field2, field3, field4, field5, field6, field7, field8, field9, field10, field11, field12, field13, field14, field15, field16, field17, field18, field19, field20, field21, field22 });
|
||||
}
|
||||
|
||||
// [jooq-tools] END [newRecord]
|
||||
// [jooq-tools] END [newRecord]
|
||||
|
||||
@Override
|
||||
public <R extends UDTRecord<R>> R newRecord(UDT<R> type) {
|
||||
@ -1585,14 +1710,14 @@ public class DefaultDSLContext implements DSLContext, Serializable {
|
||||
@Override
|
||||
public <R extends Record> R newRecord(Table<R> table, final Object source) {
|
||||
return Utils.newRecord(table, configuration)
|
||||
.operate(new RecordOperation<R, RuntimeException>() {
|
||||
.operate(new RecordOperation<R, RuntimeException>() {
|
||||
|
||||
@Override
|
||||
public R operate(R record) {
|
||||
record.from(source);
|
||||
return record;
|
||||
}
|
||||
});
|
||||
@Override
|
||||
public R operate(R record) {
|
||||
record.from(source);
|
||||
return record;
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
@Override
|
||||
@ -1670,11 +1795,13 @@ public class DefaultDSLContext implements DSLContext, Serializable {
|
||||
}
|
||||
|
||||
private final <T, R extends Record1<T>> T value1(R record) {
|
||||
if (record == null)
|
||||
if (record == null) {
|
||||
return null;
|
||||
}
|
||||
|
||||
if (record.size() != 1)
|
||||
if (record.size() != 1) {
|
||||
throw new InvalidResultException("Record contains more than one value : " + record);
|
||||
}
|
||||
|
||||
return record.value1();
|
||||
}
|
||||
|
||||
@ -1,55 +1,79 @@
|
||||
/**
|
||||
* Copyright (c) 2009-2013, Lukas Eder, lukas.eder@gmail.com
|
||||
* All rights reserved.
|
||||
*
|
||||
* This software is licensed to you under the Apache License, Version 2.0
|
||||
* (the "License"); You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Redistribution and use in source and binary forms, with or without
|
||||
* modification, are permitted provided that the following conditions are met:
|
||||
*
|
||||
* . Redistributions of source code must retain the above copyright notice, this
|
||||
* list of conditions and the following disclaimer.
|
||||
*
|
||||
* . Redistributions in binary form must reproduce the above copyright notice,
|
||||
* this list of conditions and the following disclaimer in the documentation
|
||||
* and/or other materials provided with the distribution.
|
||||
*
|
||||
* . Neither the name "jOOQ" nor the names of its contributors may be
|
||||
* used to endorse or promote products derived from this software without
|
||||
* specific prior written permission.
|
||||
*
|
||||
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
|
||||
* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
|
||||
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
|
||||
* ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
|
||||
* LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
|
||||
* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
|
||||
* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
|
||||
* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
|
||||
* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
|
||||
* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
|
||||
* POSSIBILITY OF SUCH DAMAGE.
|
||||
*/
|
||||
* Copyright (c) 2009-2013, Lukas Eder, lukas.eder@gmail.com
|
||||
* All rights reserved.
|
||||
*
|
||||
* This software is licensed to you under the Apache License, Version 2.0
|
||||
* (the "License"); You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Redistribution and use in source and binary forms, with or without
|
||||
* modification, are permitted provided that the following conditions are met:
|
||||
*
|
||||
* . Redistributions of source code must retain the above copyright notice, this
|
||||
* list of conditions and the following disclaimer.
|
||||
*
|
||||
* . Redistributions in binary form must reproduce the above copyright notice,
|
||||
* this list of conditions and the following disclaimer in the documentation
|
||||
* and/or other materials provided with the distribution.
|
||||
*
|
||||
* . Neither the name "jOOQ" nor the names of its contributors may be
|
||||
* used to endorse or promote products derived from this software without
|
||||
* specific prior written permission.
|
||||
*
|
||||
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
|
||||
* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
|
||||
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
|
||||
* ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
|
||||
* LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
|
||||
* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
|
||||
* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
|
||||
* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
|
||||
* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
|
||||
* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
|
||||
* POSSIBILITY OF SUCH DAMAGE.
|
||||
*/
|
||||
package org.jooq.impl;
|
||||
|
||||
import org.jooq.*;
|
||||
import org.jooq.exception.DataAccessException;
|
||||
import org.jooq.tools.StringUtils;
|
||||
import org.jooq.tools.csv.CSVParser;
|
||||
import org.jooq.tools.csv.CSVReader;
|
||||
import org.jooq.tools.json.JSONReader;
|
||||
import org.xml.sax.InputSource;
|
||||
|
||||
import java.io.*;
|
||||
import java.io.BufferedReader;
|
||||
import java.io.File;
|
||||
import java.io.FileNotFoundException;
|
||||
import java.io.FileReader;
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
import java.io.InputStreamReader;
|
||||
import java.io.Reader;
|
||||
import java.io.StringReader;
|
||||
import java.sql.SQLException;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Collection;
|
||||
import java.util.Iterator;
|
||||
import java.util.List;
|
||||
|
||||
import org.jooq.Condition;
|
||||
import org.jooq.Configuration;
|
||||
import org.jooq.DSLContext;
|
||||
import org.jooq.Field;
|
||||
import org.jooq.InsertQuery;
|
||||
import org.jooq.Loader;
|
||||
import org.jooq.LoaderCSVOptionsStep;
|
||||
import org.jooq.LoaderCSVStep;
|
||||
import org.jooq.LoaderError;
|
||||
import org.jooq.LoaderJSONOptionsStep;
|
||||
import org.jooq.LoaderJSONStep;
|
||||
import org.jooq.LoaderOptionsStep;
|
||||
import org.jooq.LoaderXMLStep;
|
||||
import org.jooq.SelectQuery;
|
||||
import org.jooq.Table;
|
||||
import org.jooq.TableRecord;
|
||||
import org.jooq.exception.DataAccessException;
|
||||
import org.jooq.tools.StringUtils;
|
||||
import org.jooq.tools.csv.CSVParser;
|
||||
import org.jooq.tools.csv.CSVReader;
|
||||
import org.jooq.tools.json.JSONReader;
|
||||
|
||||
import org.xml.sax.InputSource;
|
||||
|
||||
/**
|
||||
* @author Lukas Eder
|
||||
* @author Johannes Bühler
|
||||
@ -57,13 +81,8 @@ import java.util.List;
|
||||
class LoaderImpl<R extends TableRecord<R>> implements
|
||||
|
||||
// Cascading interface implementations for Loader behaviour
|
||||
LoaderOptionsStep<R>,
|
||||
LoaderXMLStep<R>,
|
||||
LoaderCSVStep<R>,
|
||||
LoaderCSVOptionsStep<R>,
|
||||
LoaderJSONStep<R>,
|
||||
LoaderJSONOptionsStep<R>,
|
||||
Loader<R> {
|
||||
LoaderOptionsStep<R>, LoaderXMLStep<R>, LoaderCSVStep<R>, LoaderCSVOptionsStep<R>, LoaderJSONStep<R>,
|
||||
LoaderJSONOptionsStep<R>, Loader<R> {
|
||||
|
||||
// Configuration constants
|
||||
// -----------------------
|
||||
@ -130,7 +149,9 @@ class LoaderImpl<R extends TableRecord<R>> implements
|
||||
@Override
|
||||
public final LoaderImpl<R> onDuplicateKeyIgnore() {
|
||||
if (table.getPrimaryKey() == null) {
|
||||
throw new IllegalStateException("ON DUPLICATE KEY IGNORE only works on tables with explicit primary keys. Table is not updatable : " + table);
|
||||
throw new IllegalStateException(
|
||||
"ON DUPLICATE KEY IGNORE only works on tables with explicit primary keys. Table is not updatable : "
|
||||
+ table);
|
||||
}
|
||||
|
||||
onDuplicate = ON_DUPLICATE_KEY_IGNORE;
|
||||
@ -140,7 +161,9 @@ class LoaderImpl<R extends TableRecord<R>> implements
|
||||
@Override
|
||||
public final LoaderImpl<R> onDuplicateKeyUpdate() {
|
||||
if (table.getPrimaryKey() == null) {
|
||||
throw new IllegalStateException("ON DUPLICATE KEY UPDATE only works on tables with explicit primary keys. Table is not updatable : " + table);
|
||||
throw new IllegalStateException(
|
||||
"ON DUPLICATE KEY UPDATE only works on tables with explicit primary keys. Table is not updatable : "
|
||||
+ table);
|
||||
}
|
||||
|
||||
onDuplicate = ON_DUPLICATE_KEY_UPDATE;
|
||||
@ -354,7 +377,8 @@ class LoaderImpl<R extends TableRecord<R>> implements
|
||||
JSONReader reader = new JSONReader(data);
|
||||
|
||||
try {
|
||||
//The current json format is not designed for streaming. Thats why all records are loaded at once.
|
||||
// The current json format is not designed for streaming. Thats why
|
||||
// all records are loaded at once.
|
||||
List<String[]> allRecords = reader.readAll();
|
||||
executeSQL(allRecords.iterator());
|
||||
}
|
||||
@ -444,8 +468,7 @@ class LoaderImpl<R extends TableRecord<R>> implements
|
||||
}
|
||||
|
||||
// Don't do anything. Let the execution fail
|
||||
else if (onDuplicate == ON_DUPLICATE_KEY_ERROR) {
|
||||
}
|
||||
else if (onDuplicate == ON_DUPLICATE_KEY_ERROR) {}
|
||||
|
||||
try {
|
||||
insert.execute();
|
||||
|
||||
Loading…
Reference in New Issue
Block a user