*/
+ @Override
public boolean equals(Object obj) {
init();
return list.equals(obj);
}
+ @Override
public int hashCode() {
init();
return list.hashCode();
@@ -219,6 +228,7 @@ public final class BeanList extends AbstractBeanCollection implements List
// proxy method for List
// -----------------------------------------------------//
+ @Override
public void add(int index, E element) {
checkReadOnly();
init();
@@ -233,6 +243,7 @@ public final class BeanList extends AbstractBeanCollection implements List
add(bean);
}
+ @Override
public boolean add(E o) {
checkReadOnly();
init();
@@ -247,6 +258,7 @@ public final class BeanList extends AbstractBeanCollection implements List
return list.add(o);
}
+ @Override
public boolean addAll(Collection extends E> c) {
checkReadOnly();
init();
@@ -257,6 +269,7 @@ public final class BeanList extends AbstractBeanCollection implements List
return list.addAll(c);
}
+ @Override
public boolean addAll(int index, Collection extends E> c) {
checkReadOnly();
init();
@@ -267,6 +280,7 @@ public final class BeanList extends AbstractBeanCollection implements List
return list.addAll(index, c);
}
+ @Override
public void clear() {
checkReadOnly();
// TODO: when clear() and not initialised could be more clever
@@ -280,31 +294,37 @@ public final class BeanList extends AbstractBeanCollection implements List
list.clear();
}
+ @Override
public boolean contains(Object o) {
init();
return list.contains(o);
}
+ @Override
public boolean containsAll(Collection> c) {
init();
return list.containsAll(c);
}
+ @Override
public E get(int index) {
init();
return list.get(index);
}
+ @Override
public int indexOf(Object o) {
init();
return list.indexOf(o);
}
+ @Override
public boolean isEmpty() {
init();
return list.isEmpty();
}
+ @Override
public Iterator iterator() {
init();
if (isReadOnly()) {
@@ -317,11 +337,13 @@ public final class BeanList extends AbstractBeanCollection implements List
return list.iterator();
}
+ @Override
public int lastIndexOf(Object o) {
init();
return list.lastIndexOf(o);
}
+ @Override
public ListIterator listIterator() {
init();
if (isReadOnly()) {
@@ -334,6 +356,7 @@ public final class BeanList extends AbstractBeanCollection implements List
return list.listIterator();
}
+ @Override
public ListIterator listIterator(int index) {
init();
if (isReadOnly()) {
@@ -353,6 +376,7 @@ public final class BeanList extends AbstractBeanCollection implements List
}
}
+ @Override
public E remove(int index) {
checkReadOnly();
init();
@@ -364,6 +388,7 @@ public final class BeanList extends AbstractBeanCollection implements List
return list.remove(index);
}
+ @Override
public boolean remove(Object o) {
checkReadOnly();
init();
@@ -377,6 +402,7 @@ public final class BeanList extends AbstractBeanCollection implements List
return list.remove(o);
}
+ @Override
public boolean removeAll(Collection> beans) {
checkReadOnly();
init();
@@ -394,6 +420,7 @@ public final class BeanList extends AbstractBeanCollection implements List
return list.removeAll(beans);
}
+ @Override
public boolean retainAll(Collection> retainBeans) {
checkReadOnly();
init();
@@ -414,6 +441,7 @@ public final class BeanList extends AbstractBeanCollection implements List
return list.retainAll(retainBeans);
}
+ @Override
public E set(int index, E element) {
checkReadOnly();
init();
@@ -426,11 +454,13 @@ public final class BeanList extends AbstractBeanCollection implements List
return list.set(index, element);
}
+ @Override
public int size() {
init();
return list.size();
}
+ @Override
public List subList(int fromIndex, int toIndex) {
init();
if (isReadOnly()) {
@@ -442,11 +472,13 @@ public final class BeanList extends AbstractBeanCollection implements List
return list.subList(fromIndex, toIndex);
}
+ @Override
public Object[] toArray() {
init();
return list.toArray();
}
+ @Override
public T[] toArray(T[] a) {
init();
//noinspection SuspiciousToArrayCall
@@ -463,38 +495,47 @@ public final class BeanList extends AbstractBeanCollection implements List
this.i = i;
}
+ @Override
public void add(E o) {
throw new IllegalStateException("This collection is in ReadOnly mode");
}
+ @Override
public void remove() {
throw new IllegalStateException("This collection is in ReadOnly mode");
}
+ @Override
public void set(E o) {
throw new IllegalStateException("This collection is in ReadOnly mode");
}
+ @Override
public boolean hasNext() {
return i.hasNext();
}
+ @Override
public boolean hasPrevious() {
return i.hasPrevious();
}
+ @Override
public E next() {
return i.next();
}
+ @Override
public int nextIndex() {
return i.nextIndex();
}
+ @Override
public E previous() {
return i.previous();
}
+ @Override
public int previousIndex() {
return i.previousIndex();
}
diff --git a/src/main/java/io/ebean/common/BeanMap.java b/src/main/java/io/ebean/common/BeanMap.java
index f9270bda2..7bf211ee1 100644
--- a/src/main/java/io/ebean/common/BeanMap.java
+++ b/src/main/java/io/ebean/common/BeanMap.java
@@ -47,6 +47,7 @@ public final class BeanMap extends AbstractBeanCollection implements Ma
this.map = null;
}
+ @Override
public boolean isSkipSave() {
return map == null || (map.isEmpty() && !holdsModifications());
}
@@ -86,6 +87,7 @@ public final class BeanMap extends AbstractBeanCollection implements Ma
throw new RuntimeException("Not allowed for map");
}
+ @Override
public void internalAdd(Object bean) {
throw new RuntimeException("Not allowed for map");
}
@@ -94,6 +96,7 @@ public final class BeanMap extends AbstractBeanCollection implements Ma
* Return true if the underlying map has been populated. Returns false if it
* has a deferred fetch pending.
*/
+ @Override
public boolean isPopulated() {
return map != null;
}
@@ -102,10 +105,12 @@ public final class BeanMap extends AbstractBeanCollection implements Ma
* Return true if this is a reference (lazy loading) bean collection. This is
* the same as !isPopulated();
*/
+ @Override
public boolean isReference() {
return map == null;
}
+ @Override
public boolean checkEmptyLazyLoad() {
if (map == null) {
map = new LinkedHashMap<>();
@@ -153,6 +158,7 @@ public final class BeanMap extends AbstractBeanCollection implements Ma
/**
* Returns the collection of beans (map values).
*/
+ @Override
public Collection getActualDetails() {
return map.values();
}
@@ -164,10 +170,12 @@ public final class BeanMap extends AbstractBeanCollection implements Ma
* they don't need to be set twice).
*
*/
+ @Override
public Collection> getActualEntries() {
return map.entrySet();
}
+ @Override
public String toString() {
StringBuilder sb = new StringBuilder(50);
sb.append("BeanMap ");
@@ -187,16 +195,19 @@ public final class BeanMap extends AbstractBeanCollection implements Ma
/**
* Equal if obj is a Map and equal in a Map sense.
*/
+ @Override
public boolean equals(Object obj) {
init();
return map.equals(obj);
}
+ @Override
public int hashCode() {
init();
return map.hashCode();
}
+ @Override
public void clear() {
checkReadOnly();
initClear();
@@ -209,16 +220,19 @@ public final class BeanMap extends AbstractBeanCollection implements Ma
map.clear();
}
+ @Override
public boolean containsKey(Object key) {
init();
return map.containsKey(key);
}
+ @Override
public boolean containsValue(Object value) {
init();
return map.containsValue(value);
}
+ @Override
@SuppressWarnings({"unchecked", "rawtypes"})
public Set> entrySet() {
init();
@@ -232,16 +246,19 @@ public final class BeanMap extends AbstractBeanCollection implements Ma
return map.entrySet();
}
+ @Override
public E get(Object key) {
init();
return map.get(key);
}
+ @Override
public boolean isEmpty() {
init();
return map.isEmpty();
}
+ @Override
public Set keySet() {
init();
if (isReadOnly()) {
@@ -251,6 +268,7 @@ public final class BeanMap extends AbstractBeanCollection implements Ma
return map.keySet();
}
+ @Override
public E put(K key, E value) {
checkReadOnly();
init();
@@ -265,6 +283,7 @@ public final class BeanMap extends AbstractBeanCollection implements Ma
return map.put(key, value);
}
+ @Override
public void putAll(Map extends K, ? extends E> puts) {
checkReadOnly();
init();
@@ -290,6 +309,7 @@ public final class BeanMap extends AbstractBeanCollection implements Ma
throw new IllegalStateException("Method not allowed on Map. Please use List instead.");
}
+ @Override
public E remove(Object key) {
checkReadOnly();
init();
@@ -301,11 +321,13 @@ public final class BeanMap extends AbstractBeanCollection implements Ma
return map.remove(key);
}
+ @Override
public int size() {
init();
return map.size();
}
+ @Override
public Collection values() {
init();
if (isReadOnly()) {
diff --git a/src/main/java/io/ebean/common/BeanSet.java b/src/main/java/io/ebean/common/BeanSet.java
index ab4972b36..e0dfa4f8d 100644
--- a/src/main/java/io/ebean/common/BeanSet.java
+++ b/src/main/java/io/ebean/common/BeanSet.java
@@ -48,10 +48,12 @@ public final class BeanSet extends AbstractBeanCollection implements Set extends AbstractBeanCollection implements Set extends AbstractBeanCollection implements Set extends AbstractBeanCollection implements Set();
@@ -142,6 +148,7 @@ public final class BeanSet extends AbstractBeanCollection implements Set getActualDetails() {
return set;
}
@@ -151,6 +158,7 @@ public final class BeanSet extends AbstractBeanCollection implements Set extends AbstractBeanCollection implements Set extends AbstractBeanCollection implements Set extends AbstractBeanCollection implements Set addCollection) {
checkReadOnly();
init();
@@ -227,6 +239,7 @@ public final class BeanSet extends AbstractBeanCollection implements Set extends AbstractBeanCollection implements Set c) {
init();
return set.containsAll(c);
}
+ @Override
public boolean isEmpty() {
init();
return set.isEmpty();
}
+ @Override
public Iterator iterator() {
init();
if (isReadOnly()) {
@@ -264,6 +281,7 @@ public final class BeanSet extends AbstractBeanCollection implements Set extends AbstractBeanCollection implements Set beans) {
checkReadOnly();
init();
@@ -293,6 +312,7 @@ public final class BeanSet extends AbstractBeanCollection implements Set beans) {
checkReadOnly();
init();
@@ -313,16 +333,19 @@ public final class BeanSet extends AbstractBeanCollection implements Set T[] toArray(T[] a) {
init();
//noinspection SuspiciousToArrayCall
@@ -339,14 +362,17 @@ public final class BeanSet extends AbstractBeanCollection implements Set implements Collection {
this.c = c;
}
+ @Override
public boolean add(E o) {
if (c.add(o)) {
owner.modifyAddition(o);
@@ -38,6 +39,7 @@ class ModifyCollection implements Collection {
return false;
}
+ @Override
public boolean addAll(Collection extends E> collection) {
boolean changed = false;
for (E o : collection) {
diff --git a/src/main/java/io/ebean/common/ModifyIterator.java b/src/main/java/io/ebean/common/ModifyIterator.java
index fbb8045d7..d4c488a85 100644
--- a/src/main/java/io/ebean/common/ModifyIterator.java
+++ b/src/main/java/io/ebean/common/ModifyIterator.java
@@ -31,15 +31,18 @@ class ModifyIterator implements Iterator {
this.it = it;
}
+ @Override
public boolean hasNext() {
return it.hasNext();
}
+ @Override
public E next() {
last = it.next();
return last;
}
+ @Override
public void remove() {
owner.modifyRemoval(last);
it.remove();
diff --git a/src/main/java/io/ebean/common/ModifyList.java b/src/main/java/io/ebean/common/ModifyList.java
index f9dcbad75..fa89d8b87 100644
--- a/src/main/java/io/ebean/common/ModifyList.java
+++ b/src/main/java/io/ebean/common/ModifyList.java
@@ -33,11 +33,13 @@ class ModifyList extends ModifyCollection implements List {
this.list = list;
}
+ @Override
public void add(int index, E element) {
list.add(index, element);
owner.modifyAddition(element);
}
+ @Override
public boolean addAll(int index, Collection extends E> addCollection) {
if (list.addAll(index, addCollection)) {
for (E bean : addCollection) {
@@ -48,32 +50,39 @@ class ModifyList extends ModifyCollection implements List {
return false;
}
+ @Override
public E get(int index) {
return list.get(index);
}
+ @Override
public int indexOf(Object o) {
return list.indexOf(o);
}
+ @Override
public int lastIndexOf(Object o) {
return list.lastIndexOf(o);
}
+ @Override
public ListIterator listIterator() {
return new ModifyListIterator<>(owner, list.listIterator());
}
+ @Override
public ListIterator listIterator(int index) {
return new ModifyListIterator<>(owner, list.listIterator(index));
}
+ @Override
public E remove(int index) {
E o = list.remove(index);
owner.modifyRemoval(o);
return o;
}
+ @Override
public E set(int index, E element) {
E o = list.set(index, element);
owner.modifyAddition(element);
@@ -81,6 +90,7 @@ class ModifyList extends ModifyCollection implements List {
return o;
}
+ @Override
public List subList(int fromIndex, int toIndex) {
return new ModifyList<>(owner, list.subList(fromIndex, toIndex));
}
diff --git a/src/main/java/io/ebean/common/ModifyListIterator.java b/src/main/java/io/ebean/common/ModifyListIterator.java
index 36dd7b3bd..207ce1251 100644
--- a/src/main/java/io/ebean/common/ModifyListIterator.java
+++ b/src/main/java/io/ebean/common/ModifyListIterator.java
@@ -28,44 +28,53 @@ class ModifyListIterator implements ListIterator {
this.it = it;
}
+ @Override
public void add(E bean) {
owner.modifyAddition(bean);
last = null;
it.add(bean);
}
+ @Override
public boolean hasNext() {
return it.hasNext();
}
+ @Override
public boolean hasPrevious() {
return it.hasPrevious();
}
+ @Override
public E next() {
last = it.next();
return last;
}
+ @Override
public int nextIndex() {
return it.nextIndex();
}
+ @Override
public E previous() {
last = it.previous();
return last;
}
+ @Override
public int previousIndex() {
return it.previousIndex();
}
+ @Override
public void remove() {
owner.modifyRemoval(last);
last = null;
it.remove();
}
+ @Override
public void set(E o) {
if (last != null) {
owner.modifyRemoval(last);
diff --git a/src/main/java/io/ebean/config/AbstractNamingConvention.java b/src/main/java/io/ebean/config/AbstractNamingConvention.java
index 9d77a42e9..e97d7a5db 100644
--- a/src/main/java/io/ebean/config/AbstractNamingConvention.java
+++ b/src/main/java/io/ebean/config/AbstractNamingConvention.java
@@ -76,10 +76,12 @@ public abstract class AbstractNamingConvention implements NamingConvention {
this(DEFAULT_SEQ_FORMAT);
}
+ @Override
public void setDatabasePlatform(DatabasePlatform databasePlatform) {
this.databasePlatform = databasePlatform;
}
+ @Override
public String getSequenceName(String tableName, String pkColumn) {
String s = sequenceFormat.replace("{table}", tableName);
if (pkColumn == null) {
@@ -152,6 +154,7 @@ public abstract class AbstractNamingConvention implements NamingConvention {
* column names.
*
*/
+ @Override
public boolean isUseForeignKeyPrefix() {
return useForeignKeyPrefix;
}
@@ -180,6 +183,7 @@ public abstract class AbstractNamingConvention implements NamingConvention {
* @see #getTableNameFromAnnotation(Class)
* @see #getTableNameByConvention(Class)
*/
+ @Override
public TableName getTableName(Class> beanClass) {
TableName tableName = getTableNameFromAnnotation(beanClass);
@@ -221,6 +225,7 @@ public abstract class AbstractNamingConvention implements NamingConvention {
return supCls.getAnnotation(annotation) != null;
}
+ @Override
public TableName getM2MJoinTableName(TableName lhsTable, TableName rhsTable) {
StringBuilder buffer = new StringBuilder();
diff --git a/src/main/java/io/ebean/config/MatchingNamingConvention.java b/src/main/java/io/ebean/config/MatchingNamingConvention.java
index d351631e6..10a62c582 100644
--- a/src/main/java/io/ebean/config/MatchingNamingConvention.java
+++ b/src/main/java/io/ebean/config/MatchingNamingConvention.java
@@ -29,15 +29,18 @@ public class MatchingNamingConvention extends AbstractNamingConvention {
super(sequenceFormat);
}
+ @Override
public String getColumnFromProperty(Class> beanClass, String propertyName) {
return propertyName;
}
+ @Override
public TableName getTableNameByConvention(Class> beanClass) {
return new TableName(getCatalog(), getSchema(), beanClass.getSimpleName());
}
+ @Override
public String getPropertyFromColumn(Class> beanClass, String dbColumnName) {
return dbColumnName;
}
diff --git a/src/main/java/io/ebean/config/PropertyMap.java b/src/main/java/io/ebean/config/PropertyMap.java
index eb8069b00..2da152d78 100644
--- a/src/main/java/io/ebean/config/PropertyMap.java
+++ b/src/main/java/io/ebean/config/PropertyMap.java
@@ -36,6 +36,7 @@ public final class PropertyMap implements Serializable {
return (disable == null || !disable.equalsIgnoreCase("true"));
}
+ @Override
public String toString() {
return map.toString();
}
diff --git a/src/main/java/io/ebean/config/TableName.java b/src/main/java/io/ebean/config/TableName.java
index c75e89329..dba8b1d0d 100644
--- a/src/main/java/io/ebean/config/TableName.java
+++ b/src/main/java/io/ebean/config/TableName.java
@@ -69,6 +69,7 @@ public final class TableName {
return new TableName(qualifiedTableName).getName();
}
+ @Override
public String toString() {
return getQualifiedName();
}
diff --git a/src/main/java/io/ebean/config/UnderscoreNamingConvention.java b/src/main/java/io/ebean/config/UnderscoreNamingConvention.java
index 4a5041d53..8fffed5fb 100644
--- a/src/main/java/io/ebean/config/UnderscoreNamingConvention.java
+++ b/src/main/java/io/ebean/config/UnderscoreNamingConvention.java
@@ -43,6 +43,7 @@ public class UnderscoreNamingConvention extends AbstractNamingConvention {
* @param beanClass the bean class
* @return the table name from class
*/
+ @Override
public TableName getTableNameByConvention(Class> beanClass) {
return new TableName(getCatalog(), getSchema(), toUnderscoreFromCamel(beanClass.getSimpleName()));
@@ -53,6 +54,7 @@ public class UnderscoreNamingConvention extends AbstractNamingConvention {
*
* @return the column from property
*/
+ @Override
public String getColumnFromProperty(Class> beanClass, String propertyName) {
return toUnderscoreFromCamel(propertyName);
@@ -65,6 +67,7 @@ public class UnderscoreNamingConvention extends AbstractNamingConvention {
* @param dbColumnName the db column name
* @return the property from column
*/
+ @Override
public String getPropertyFromColumn(Class> beanClass, String dbColumnName) {
return toCamelFromUnderscore(dbColumnName);
}
diff --git a/src/main/java/io/ebean/config/dbplatform/AbstractDbEncrypt.java b/src/main/java/io/ebean/config/dbplatform/AbstractDbEncrypt.java
index 4e5f2072e..e4bee6ab9 100644
--- a/src/main/java/io/ebean/config/dbplatform/AbstractDbEncrypt.java
+++ b/src/main/java/io/ebean/config/dbplatform/AbstractDbEncrypt.java
@@ -39,6 +39,7 @@ public abstract class AbstractDbEncrypt implements DbEncrypt {
* Null is returned if DB encryption of the type is not supported.
*
*/
+ @Override
public DbEncryptFunction getDbEncryptFunction(int jdbcType) {
switch (jdbcType) {
case Types.VARCHAR:
@@ -64,6 +65,7 @@ public abstract class AbstractDbEncrypt implements DbEncrypt {
/**
* Return the DB stored type for encrypted properties.
*/
+ @Override
public int getEncryptDbType() {
return Types.VARBINARY;
}
@@ -71,6 +73,7 @@ public abstract class AbstractDbEncrypt implements DbEncrypt {
/**
* Generally encrypt function binding the data before the key (except h2).
*/
+ @Override
public boolean isBindEncryptDataFirst() {
return true;
}
diff --git a/src/main/java/io/ebean/config/dbplatform/LimitOffsetSqlLimiter.java b/src/main/java/io/ebean/config/dbplatform/LimitOffsetSqlLimiter.java
index f80bc6cc5..81f9b7625 100644
--- a/src/main/java/io/ebean/config/dbplatform/LimitOffsetSqlLimiter.java
+++ b/src/main/java/io/ebean/config/dbplatform/LimitOffsetSqlLimiter.java
@@ -15,6 +15,7 @@ public class LimitOffsetSqlLimiter implements SqlLimiter {
*/
private static final String OFFSET = "offset";
+ @Override
public SqlLimitResponse limit(SqlLimitRequest request) {
String dbSql = request.getDbSql();
diff --git a/src/main/java/io/ebean/config/dbplatform/RowNumberSqlLimiter.java b/src/main/java/io/ebean/config/dbplatform/RowNumberSqlLimiter.java
index 3504ab437..9f6b4ad19 100644
--- a/src/main/java/io/ebean/config/dbplatform/RowNumberSqlLimiter.java
+++ b/src/main/java/io/ebean/config/dbplatform/RowNumberSqlLimiter.java
@@ -28,6 +28,7 @@ public class RowNumberSqlLimiter implements SqlLimiter {
this("as limitresult");
}
+ @Override
public SqlLimitResponse limit(SqlLimitRequest request) {
String dbSql = request.getDbSql();
diff --git a/src/main/java/io/ebean/config/dbplatform/RownumSqlLimiter.java b/src/main/java/io/ebean/config/dbplatform/RownumSqlLimiter.java
index 265e45f99..ef7656782 100644
--- a/src/main/java/io/ebean/config/dbplatform/RownumSqlLimiter.java
+++ b/src/main/java/io/ebean/config/dbplatform/RownumSqlLimiter.java
@@ -25,6 +25,7 @@ public class RownumSqlLimiter implements SqlLimiter {
this.useFirstRowsHint = useFirstRowsHint;
}
+ @Override
public SqlLimitResponse limit(SqlLimitRequest request) {
// select *
diff --git a/src/main/java/io/ebean/config/dbplatform/SequenceIdGenerator.java b/src/main/java/io/ebean/config/dbplatform/SequenceIdGenerator.java
index 2511b8b61..0c6399726 100644
--- a/src/main/java/io/ebean/config/dbplatform/SequenceIdGenerator.java
+++ b/src/main/java/io/ebean/config/dbplatform/SequenceIdGenerator.java
@@ -60,6 +60,7 @@ public abstract class SequenceIdGenerator implements PlatformIdGenerator {
/**
* Returns the sequence name.
*/
+ @Override
public String getName() {
return seqName;
}
@@ -67,6 +68,7 @@ public abstract class SequenceIdGenerator implements PlatformIdGenerator {
/**
* Returns true.
*/
+ @Override
public boolean isDbSequence() {
return true;
}
@@ -78,6 +80,7 @@ public abstract class SequenceIdGenerator implements PlatformIdGenerator {
* beans Ebean can call this to ensure .
*
*/
+ @Override
public void preAllocateIds(int allocateSize) {
if (batchSize > 1 && allocateSize > batchSize) {
// only bother if allocateSize is bigger than
@@ -106,6 +109,7 @@ public abstract class SequenceIdGenerator implements PlatformIdGenerator {
* If a Transaction has been passed in use the Connection from it.
*
*/
+ @Override
public Object nextId(Transaction t) {
synchronized (monitor) {
diff --git a/src/main/java/io/ebean/config/dbplatform/SimpleSequenceIdGenerator.java b/src/main/java/io/ebean/config/dbplatform/SimpleSequenceIdGenerator.java
index 0437f46e7..902579384 100644
--- a/src/main/java/io/ebean/config/dbplatform/SimpleSequenceIdGenerator.java
+++ b/src/main/java/io/ebean/config/dbplatform/SimpleSequenceIdGenerator.java
@@ -36,18 +36,22 @@ public class SimpleSequenceIdGenerator implements PlatformIdGenerator {
this.seqName = seqName;
}
+ @Override
public String getName() {
return seqName;
}
+ @Override
public boolean isDbSequence() {
return true;
}
+ @Override
public void preAllocateIds(int batchSize) {
// just ignore this
}
+ @Override
public Object nextId(Transaction t) {
boolean useTxnConnection = t != null;
diff --git a/src/main/java/io/ebean/config/dbplatform/db2/DB2SequenceIdGenerator.java b/src/main/java/io/ebean/config/dbplatform/db2/DB2SequenceIdGenerator.java
index 43daa34d7..788e4e396 100644
--- a/src/main/java/io/ebean/config/dbplatform/db2/DB2SequenceIdGenerator.java
+++ b/src/main/java/io/ebean/config/dbplatform/db2/DB2SequenceIdGenerator.java
@@ -22,6 +22,7 @@ public class DB2SequenceIdGenerator extends SequenceIdGenerator {
this.unionBaseSql = " union " + baseSql;
}
+ @Override
public String getSql(int batchSize) {
StringBuilder sb = new StringBuilder();
diff --git a/src/main/java/io/ebean/config/dbplatform/h2/H2DbEncrypt.java b/src/main/java/io/ebean/config/dbplatform/h2/H2DbEncrypt.java
index e4c00972a..ec7b1d9a7 100644
--- a/src/main/java/io/ebean/config/dbplatform/h2/H2DbEncrypt.java
+++ b/src/main/java/io/ebean/config/dbplatform/h2/H2DbEncrypt.java
@@ -18,17 +18,20 @@ public class H2DbEncrypt extends AbstractDbEncrypt {
/**
* For H2 encrypt function returns false binding the key before the data.
*/
+ @Override
public boolean isBindEncryptDataFirst() {
return false;
}
private static class H2VarcharFunction implements DbEncryptFunction {
+ @Override
public String getDecryptSql(String columnWithTableAlias) {
// Hmmm, this looks ugly - checking with H2 Database folks.
return "TRIM(CHAR(0) FROM UTF8TOSTRING(DECRYPT('AES', STRINGTOUTF8(?), " + columnWithTableAlias + ")))";
}
+ @Override
public String getEncryptBindSql() {
return "ENCRYPT('AES', STRINGTOUTF8(?), STRINGTOUTF8(?))";
}
@@ -37,10 +40,12 @@ public class H2DbEncrypt extends AbstractDbEncrypt {
private static class H2DateFunction implements DbEncryptFunction {
+ @Override
public String getDecryptSql(String columnWithTableAlias) {
return "PARSEDATETIME(TRIM(CHAR(0) FROM UTF8TOSTRING(DECRYPT('AES', STRINGTOUTF8(?), " + columnWithTableAlias + "))),'yyyyMMdd')";
}
+ @Override
public String getEncryptBindSql() {
return "ENCRYPT('AES', STRINGTOUTF8(?), STRINGTOUTF8(FORMATDATETIME(?,'yyyyMMdd')))";
}
diff --git a/src/main/java/io/ebean/config/dbplatform/h2/H2SequenceIdGenerator.java b/src/main/java/io/ebean/config/dbplatform/h2/H2SequenceIdGenerator.java
index ab4482614..4dafed231 100644
--- a/src/main/java/io/ebean/config/dbplatform/h2/H2SequenceIdGenerator.java
+++ b/src/main/java/io/ebean/config/dbplatform/h2/H2SequenceIdGenerator.java
@@ -22,6 +22,7 @@ public class H2SequenceIdGenerator extends SequenceIdGenerator {
this.unionBaseSql = " union " + baseSql;
}
+ @Override
public String getSql(int batchSize) {
StringBuilder sb = new StringBuilder();
diff --git a/src/main/java/io/ebean/config/dbplatform/mysql/MySqlDbEncrypt.java b/src/main/java/io/ebean/config/dbplatform/mysql/MySqlDbEncrypt.java
index 6dc3f2e60..2a22d8ab2 100644
--- a/src/main/java/io/ebean/config/dbplatform/mysql/MySqlDbEncrypt.java
+++ b/src/main/java/io/ebean/config/dbplatform/mysql/MySqlDbEncrypt.java
@@ -17,10 +17,12 @@ public class MySqlDbEncrypt extends AbstractDbEncrypt {
private static class MyVarcharFunction implements DbEncryptFunction {
+ @Override
public String getDecryptSql(String columnWithTableAlias) {
return "CONVERT(AES_DECRYPT(" + columnWithTableAlias + ",?) USING UTF8)";
}
+ @Override
public String getEncryptBindSql() {
return "AES_ENCRYPT(?,?)";
}
@@ -28,10 +30,12 @@ public class MySqlDbEncrypt extends AbstractDbEncrypt {
private static class MyDateFunction implements DbEncryptFunction {
+ @Override
public String getDecryptSql(String columnWithTableAlias) {
return "STR_TO_DATE(AES_DECRYPT(" + columnWithTableAlias + ",?),'%Y%d%m')";
}
+ @Override
public String getEncryptBindSql() {
return "AES_ENCRYPT(DATE_FORMAT(?,'%Y%d%m'),?)";
}
diff --git a/src/main/java/io/ebean/config/dbplatform/oracle/OracleDbEncrypt.java b/src/main/java/io/ebean/config/dbplatform/oracle/OracleDbEncrypt.java
index bdfc5562b..e1194ac37 100644
--- a/src/main/java/io/ebean/config/dbplatform/oracle/OracleDbEncrypt.java
+++ b/src/main/java/io/ebean/config/dbplatform/oracle/OracleDbEncrypt.java
@@ -78,10 +78,12 @@ public class OracleDbEncrypt extends AbstractDbEncrypt {
this.decryptfunction = decryptfunction;
}
+ @Override
public String getDecryptSql(String columnWithTableAlias) {
return decryptfunction + "(" + columnWithTableAlias + ",?)";
}
+ @Override
public String getEncryptBindSql() {
return encryptfunction + "(?,?)";
}
@@ -101,10 +103,12 @@ public class OracleDbEncrypt extends AbstractDbEncrypt {
this.decryptfunction = decryptfunction;
}
+ @Override
public String getDecryptSql(String columnWithTableAlias) {
return "to_date(" + decryptfunction + "(" + columnWithTableAlias + ",?),'YYYYMMDD')";
}
+ @Override
public String getEncryptBindSql() {
return encryptfunction + "(to_char(?,'YYYYMMDD'),?)";
}
diff --git a/src/main/java/io/ebean/config/dbplatform/oracle/OracleSequenceIdGenerator.java b/src/main/java/io/ebean/config/dbplatform/oracle/OracleSequenceIdGenerator.java
index b5bc283b7..b0a7a2f70 100644
--- a/src/main/java/io/ebean/config/dbplatform/oracle/OracleSequenceIdGenerator.java
+++ b/src/main/java/io/ebean/config/dbplatform/oracle/OracleSequenceIdGenerator.java
@@ -20,6 +20,7 @@ public class OracleSequenceIdGenerator extends SequenceIdGenerator {
this.baseSql = "select " + seqName + ".nextval, a from (select level as a FROM dual CONNECT BY level <= ";
}
+ @Override
public String getSql(int batchSize) {
return baseSql + batchSize + ")";
}
diff --git a/src/main/java/io/ebean/config/dbplatform/postgres/PostgresDbEncrypt.java b/src/main/java/io/ebean/config/dbplatform/postgres/PostgresDbEncrypt.java
index a4e36f699..b2d24aaf3 100644
--- a/src/main/java/io/ebean/config/dbplatform/postgres/PostgresDbEncrypt.java
+++ b/src/main/java/io/ebean/config/dbplatform/postgres/PostgresDbEncrypt.java
@@ -15,10 +15,12 @@ public class PostgresDbEncrypt extends AbstractDbEncrypt {
private static class PgVarcharFunction implements DbEncryptFunction {
+ @Override
public String getDecryptSql(String columnWithTableAlias) {
return "pgp_sym_decrypt(" + columnWithTableAlias + ",?)";
}
+ @Override
public String getEncryptBindSql() {
return "pgp_sym_encrypt(?,?)";
}
@@ -26,10 +28,12 @@ public class PostgresDbEncrypt extends AbstractDbEncrypt {
private static class PgDateFunction implements DbEncryptFunction {
+ @Override
public String getDecryptSql(String columnWithTableAlias) {
return "to_date(pgp_sym_decrypt(" + columnWithTableAlias + ",?),'YYYYMMDD')";
}
+ @Override
public String getEncryptBindSql() {
return "pgp_sym_encrypt(to_char(?::date,'YYYYMMDD'),?)";
}
diff --git a/src/main/java/io/ebean/config/dbplatform/postgres/PostgresPlatform.java b/src/main/java/io/ebean/config/dbplatform/postgres/PostgresPlatform.java
index 374aa28d9..1ec7ef667 100644
--- a/src/main/java/io/ebean/config/dbplatform/postgres/PostgresPlatform.java
+++ b/src/main/java/io/ebean/config/dbplatform/postgres/PostgresPlatform.java
@@ -70,6 +70,7 @@ public class PostgresPlatform extends DatabasePlatform {
dbTypeMap.put(DbType.LONGVARCHAR, dbTypeText);
}
+ @Override
protected void addGeoTypes(int srid) {
dbTypeMap.put(DbType.POINT, geoType("point", srid));
dbTypeMap.put(DbType.POLYGON, geoType("polygon", srid));
@@ -86,6 +87,7 @@ public class PostgresPlatform extends DatabasePlatform {
/**
* Return a DdlHandler instance for generating DDL for the specific platform.
*/
+ @Override
public DdlHandler createDdlHandler(ServerConfig serverConfig) {
return this.platformDdl.createDdlHandler(serverConfig);
}
diff --git a/src/main/java/io/ebean/config/dbplatform/postgres/PostgresSequenceIdGenerator.java b/src/main/java/io/ebean/config/dbplatform/postgres/PostgresSequenceIdGenerator.java
index e55334e35..d01a70db5 100644
--- a/src/main/java/io/ebean/config/dbplatform/postgres/PostgresSequenceIdGenerator.java
+++ b/src/main/java/io/ebean/config/dbplatform/postgres/PostgresSequenceIdGenerator.java
@@ -20,6 +20,7 @@ public class PostgresSequenceIdGenerator extends SequenceIdGenerator {
this.baseSql = "select nextval('" + seqName + "'), s.generate_series from (select generate_series from generate_series(1,";
}
+ @Override
public String getSql(int batchSize) {
return baseSql + batchSize + ") ) as s";
}
diff --git a/src/main/java/io/ebean/config/dbplatform/sqlanywhere/SqlAnywhereLimiter.java b/src/main/java/io/ebean/config/dbplatform/sqlanywhere/SqlAnywhereLimiter.java
index d07011808..a304fc8f8 100644
--- a/src/main/java/io/ebean/config/dbplatform/sqlanywhere/SqlAnywhereLimiter.java
+++ b/src/main/java/io/ebean/config/dbplatform/sqlanywhere/SqlAnywhereLimiter.java
@@ -9,6 +9,7 @@ import io.ebean.config.dbplatform.SqlLimiter;
*/
public class SqlAnywhereLimiter implements SqlLimiter {
+ @Override
public SqlLimitResponse limit(SqlLimitRequest request) {
String dbSql = request.getDbSql();
diff --git a/src/main/java/io/ebean/config/dbplatform/sqlserver/SqlServer2005SqlLimiter.java b/src/main/java/io/ebean/config/dbplatform/sqlserver/SqlServer2005SqlLimiter.java
index f73e41f37..cccef861e 100644
--- a/src/main/java/io/ebean/config/dbplatform/sqlserver/SqlServer2005SqlLimiter.java
+++ b/src/main/java/io/ebean/config/dbplatform/sqlserver/SqlServer2005SqlLimiter.java
@@ -22,6 +22,7 @@ public class SqlServer2005SqlLimiter implements SqlLimiter {
this("as limitresult");
}
+ @Override
public SqlLimitResponse limit(SqlLimitRequest request) {
StringBuilder sb = new StringBuilder(500);
diff --git a/src/main/java/io/ebean/config/dbplatform/sqlserver/SqlServerSqlLimiter.java b/src/main/java/io/ebean/config/dbplatform/sqlserver/SqlServerSqlLimiter.java
index f8b7a70a3..0ca126b34 100644
--- a/src/main/java/io/ebean/config/dbplatform/sqlserver/SqlServerSqlLimiter.java
+++ b/src/main/java/io/ebean/config/dbplatform/sqlserver/SqlServerSqlLimiter.java
@@ -12,6 +12,7 @@ public class SqlServerSqlLimiter implements SqlLimiter {
public SqlServerSqlLimiter() {
}
+ @Override
public SqlLimitResponse limit(SqlLimitRequest request) {
String dbSql = request.getDbSql();
diff --git a/src/main/java/io/ebean/dbmigration/ddlgeneration/platform/BaseDdlBuffer.java b/src/main/java/io/ebean/dbmigration/ddlgeneration/platform/BaseDdlBuffer.java
index 138d15cc2..bf44201b9 100644
--- a/src/main/java/io/ebean/dbmigration/ddlgeneration/platform/BaseDdlBuffer.java
+++ b/src/main/java/io/ebean/dbmigration/ddlgeneration/platform/BaseDdlBuffer.java
@@ -83,6 +83,7 @@ public class BaseDdlBuffer implements DdlBuffer {
return this;
}
+ @Override
public String getBuffer() {
return writer.toString();
}
diff --git a/src/main/java/io/ebean/dbmigration/ddlgeneration/platform/DefaultConstraintMaxLength.java b/src/main/java/io/ebean/dbmigration/ddlgeneration/platform/DefaultConstraintMaxLength.java
index d41795317..dbd77ee90 100644
--- a/src/main/java/io/ebean/dbmigration/ddlgeneration/platform/DefaultConstraintMaxLength.java
+++ b/src/main/java/io/ebean/dbmigration/ddlgeneration/platform/DefaultConstraintMaxLength.java
@@ -19,6 +19,7 @@ public class DefaultConstraintMaxLength implements DbConstraintNaming.MaxLength
*
* This implementation should work well apart from perhaps DB2 where the limit is 18.
*/
+ @Override
public String maxLength(String constraintName, int count) {
if (constraintName.length() < maxConstraintNameLength) {
return constraintName;
diff --git a/src/main/java/io/ebean/dbmigration/ddlgeneration/platform/HistoryTableUpdate.java b/src/main/java/io/ebean/dbmigration/ddlgeneration/platform/HistoryTableUpdate.java
index 33d5e873a..94109cb25 100644
--- a/src/main/java/io/ebean/dbmigration/ddlgeneration/platform/HistoryTableUpdate.java
+++ b/src/main/java/io/ebean/dbmigration/ddlgeneration/platform/HistoryTableUpdate.java
@@ -31,6 +31,7 @@ public class HistoryTableUpdate {
this.column = column;
}
+ @Override
public String toString() {
return description();
}
diff --git a/src/main/java/io/ebean/dbmigration/ddlgeneration/platform/MySqlDdl.java b/src/main/java/io/ebean/dbmigration/ddlgeneration/platform/MySqlDdl.java
index 75372efd7..692d575b7 100644
--- a/src/main/java/io/ebean/dbmigration/ddlgeneration/platform/MySqlDdl.java
+++ b/src/main/java/io/ebean/dbmigration/ddlgeneration/platform/MySqlDdl.java
@@ -49,12 +49,14 @@ public class MySqlDdl extends PlatformDdl {
return null;
}
+ @Override
public String alterColumnNotnull(String tableName, String columnName, boolean notnull) {
// can't alter itself - done in alterColumnBaseAttributes()
return null;
}
+ @Override
public String alterColumnDefaultValue(String tableName, String columnName, String defaultValue) {
String suffix = isDropDefault(defaultValue) ? columnDropDefault : columnSetDefault + " " + defaultValue;
@@ -63,6 +65,7 @@ public class MySqlDdl extends PlatformDdl {
return "alter table " + tableName + " alter " + columnName + " " + suffix;
}
+ @Override
public String alterColumnBaseAttributes(AlterColumn alter) {
String tableName = alter.getTableName();
@@ -89,6 +92,7 @@ public class MySqlDdl extends PlatformDdl {
}
+ @Override
public void inlineTableComment(DdlBuffer apply, String tableComment) throws IOException {
if (tableComment.length() > 1000) {
tableComment = tableComment.substring(0, 1000);
diff --git a/src/main/java/io/ebean/dbmigration/ddlgeneration/platform/SqlServerDdl.java b/src/main/java/io/ebean/dbmigration/ddlgeneration/platform/SqlServerDdl.java
index 1ed1c1b60..6b5814274 100644
--- a/src/main/java/io/ebean/dbmigration/ddlgeneration/platform/SqlServerDdl.java
+++ b/src/main/java/io/ebean/dbmigration/ddlgeneration/platform/SqlServerDdl.java
@@ -64,6 +64,7 @@ public class SqlServerDdl extends PlatformDdl {
}
}
+ @Override
public String alterColumnBaseAttributes(AlterColumn alter) {
String tableName = alter.getTableName();
@@ -82,6 +83,7 @@ public class SqlServerDdl extends PlatformDdl {
return null;
}
+ @Override
public String alterColumnNotnull(String tableName, String columnName, boolean notnull) {
// can't alter itself - done in alterColumnBaseAttributes()
@@ -91,6 +93,7 @@ public class SqlServerDdl extends PlatformDdl {
/**
* Add table comment as a separate statement (from the create table statement).
*/
+ @Override
public void addTableComment(DdlBuffer apply, String tableName, String tableComment) throws IOException {
// do nothing for MS SQL Server (cause it requires stored procedures etc)
@@ -99,6 +102,7 @@ public class SqlServerDdl extends PlatformDdl {
/**
* Add column comment as a separate statement.
*/
+ @Override
public void addColumnComment(DdlBuffer apply, String table, String column, String comment) throws IOException {
// do nothing for MS SQL Server (cause it requires stored procedures etc)
diff --git a/src/main/java/io/ebean/dbmigration/model/MigrationResource.java b/src/main/java/io/ebean/dbmigration/model/MigrationResource.java
index 75d9f710c..0e70aced3 100644
--- a/src/main/java/io/ebean/dbmigration/model/MigrationResource.java
+++ b/src/main/java/io/ebean/dbmigration/model/MigrationResource.java
@@ -22,6 +22,7 @@ public class MigrationResource implements Comparable {
this.version = version;
}
+ @Override
public String toString() {
return migrationFile.getName();
}
diff --git a/src/main/java/io/ebean/dbmigration/model/MigrationVersion.java b/src/main/java/io/ebean/dbmigration/model/MigrationVersion.java
index e78d20308..6cad47b2a 100644
--- a/src/main/java/io/ebean/dbmigration/model/MigrationVersion.java
+++ b/src/main/java/io/ebean/dbmigration/model/MigrationVersion.java
@@ -59,6 +59,7 @@ public class MigrationVersion implements Comparable {
return raw;
}
+ @Override
public String toString() {
return raw;
}
diff --git a/src/main/java/io/ebean/dbmigration/model/build/ModelBuildBeanVisitor.java b/src/main/java/io/ebean/dbmigration/model/build/ModelBuildBeanVisitor.java
index 4cd623802..dc9f09b5b 100644
--- a/src/main/java/io/ebean/dbmigration/model/build/ModelBuildBeanVisitor.java
+++ b/src/main/java/io/ebean/dbmigration/model/build/ModelBuildBeanVisitor.java
@@ -28,6 +28,7 @@ public class ModelBuildBeanVisitor implements BeanVisitor {
* This creates an MTable and adds it to the model.
*
*/
+ @Override
public ModelBuildPropertyVisitor visitBean(BeanDescriptor> descriptor) {
if (!descriptor.isInheritanceRoot()) {
diff --git a/src/main/java/io/ebean/dbmigration/model/visitor/BaseTablePropertyVisitor.java b/src/main/java/io/ebean/dbmigration/model/visitor/BaseTablePropertyVisitor.java
index 0244a8d28..73d489fb1 100644
--- a/src/main/java/io/ebean/dbmigration/model/visitor/BaseTablePropertyVisitor.java
+++ b/src/main/java/io/ebean/dbmigration/model/visitor/BaseTablePropertyVisitor.java
@@ -13,34 +13,40 @@ public abstract class BaseTablePropertyVisitor implements BeanPropertyVisitor {
/**
* Not required in that you can use the visitEmbeddedScalar.
*/
+ @Override
public void visitEmbedded(BeanPropertyAssocOne> p) {
}
/**
* Override this method.
*/
+ @Override
public abstract void visitEmbeddedScalar(BeanProperty p, BeanPropertyAssocOne> embedded);
/**
* Not part of base table.
*/
+ @Override
public void visitMany(BeanPropertyAssocMany> p) {
}
/**
* Not part of base table.
*/
+ @Override
public void visitOneExported(BeanPropertyAssocOne> p) {
}
/**
* Override this method for the foreign key.
*/
+ @Override
public abstract void visitOneImported(BeanPropertyAssocOne> p);
/**
* Override this method for normal scalar property.
*/
+ @Override
public abstract void visitScalar(BeanProperty p);
}
diff --git a/src/main/java/io/ebean/dbmigration/model/visitor/VisitAllUsing.java b/src/main/java/io/ebean/dbmigration/model/visitor/VisitAllUsing.java
index a17497810..00716b711 100644
--- a/src/main/java/io/ebean/dbmigration/model/visitor/VisitAllUsing.java
+++ b/src/main/java/io/ebean/dbmigration/model/visitor/VisitAllUsing.java
@@ -137,6 +137,7 @@ public class VisitAllUsing {
this.pv = pv;
}
+ @Override
public void visit(InheritInfo inheritInfo) {
BeanProperty[] propertiesLocal = inheritInfo.desc().propertiesLocal();
for (BeanProperty aPropertiesLocal : propertiesLocal) {
diff --git a/src/main/java/io/ebean/event/BeanPersistAdapter.java b/src/main/java/io/ebean/event/BeanPersistAdapter.java
index 06056e7a8..6e38ce2aa 100644
--- a/src/main/java/io/ebean/event/BeanPersistAdapter.java
+++ b/src/main/java/io/ebean/event/BeanPersistAdapter.java
@@ -14,6 +14,7 @@ import io.ebean.config.ServerConfig;
*/
public abstract class BeanPersistAdapter implements BeanPersistController {
+ @Override
public abstract boolean isRegisterFor(Class> cls);
/**
@@ -21,6 +22,7 @@ public abstract class BeanPersistAdapter implements BeanPersistController {
* BeanPersistController's are executed when there is multiple of them
* registered for a given entity type (class).
*/
+ @Override
public int getExecutionOrder() {
return 10;
}
@@ -28,6 +30,7 @@ public abstract class BeanPersistAdapter implements BeanPersistController {
/**
* Returns true indicating normal processing should continue.
*/
+ @Override
public boolean preDelete(BeanPersistRequest> request) {
return true;
}
@@ -35,6 +38,7 @@ public abstract class BeanPersistAdapter implements BeanPersistController {
/**
* Returns true indicating normal processing should continue.
*/
+ @Override
public boolean preInsert(BeanPersistRequest> request) {
return true;
}
@@ -42,6 +46,7 @@ public abstract class BeanPersistAdapter implements BeanPersistController {
/**
* Returns true indicating normal processing should continue.
*/
+ @Override
public boolean preUpdate(BeanPersistRequest> request) {
return true;
}
@@ -49,6 +54,7 @@ public abstract class BeanPersistAdapter implements BeanPersistController {
/**
* Returns true indicating normal processing should continue.
*/
+ @Override
public boolean preSoftDelete(BeanPersistRequest> request) {
return true;
}
@@ -56,24 +62,28 @@ public abstract class BeanPersistAdapter implements BeanPersistController {
/**
* Does nothing by default.
*/
+ @Override
public void postDelete(BeanPersistRequest> request) {
}
/**
* Does nothing by default.
*/
+ @Override
public void postInsert(BeanPersistRequest> request) {
}
/**
* Does nothing by default.
*/
+ @Override
public void postUpdate(BeanPersistRequest> request) {
}
/**
* Does nothing by default.
*/
+ @Override
public void postSoftDelete(BeanPersistRequest> request) {
}
diff --git a/src/main/java/io/ebean/event/changelog/BeanChange.java b/src/main/java/io/ebean/event/changelog/BeanChange.java
index 83df95e16..c7fe3186f 100644
--- a/src/main/java/io/ebean/event/changelog/BeanChange.java
+++ b/src/main/java/io/ebean/event/changelog/BeanChange.java
@@ -51,6 +51,7 @@ public class BeanChange {
public BeanChange() {
}
+ @Override
public String toString() {
return "table:" + table + " id:" + id + " values:" + values;
}
diff --git a/src/main/java/io/ebean/event/changelog/ChangeSet.java b/src/main/java/io/ebean/event/changelog/ChangeSet.java
index 0891edb9d..252f4bcab 100644
--- a/src/main/java/io/ebean/event/changelog/ChangeSet.java
+++ b/src/main/java/io/ebean/event/changelog/ChangeSet.java
@@ -66,6 +66,7 @@ public class ChangeSet {
public ChangeSet() {
}
+ @Override
public String toString() {
return "txnId:" + txnId + " txnState:" + txnState + " txnBatch:" + txnBatch;
}
diff --git a/src/main/java/io/ebean/event/readaudit/ReadAuditQueryPlan.java b/src/main/java/io/ebean/event/readaudit/ReadAuditQueryPlan.java
index 4bb284330..aff5aa656 100644
--- a/src/main/java/io/ebean/event/readaudit/ReadAuditQueryPlan.java
+++ b/src/main/java/io/ebean/event/readaudit/ReadAuditQueryPlan.java
@@ -29,6 +29,7 @@ public class ReadAuditQueryPlan {
public ReadAuditQueryPlan() {
}
+ @Override
public String toString() {
return "beanType:" + beanType + " queryKey:" + queryKey + " sql:" + sql;
}
diff --git a/src/main/java/io/ebean/text/PathProperties.java b/src/main/java/io/ebean/text/PathProperties.java
index 642704cdb..3775ef6ee 100644
--- a/src/main/java/io/ebean/text/PathProperties.java
+++ b/src/main/java/io/ebean/text/PathProperties.java
@@ -46,6 +46,7 @@ public class PathProperties implements FetchPath {
this.pathMap.put(null, rootProps);
}
+ @Override
public String toString() {
return pathMap.toString();
}
@@ -103,6 +104,7 @@ public class PathProperties implements FetchPath {
/**
* Apply these path properties as fetch paths to the query.
*/
+ @Override
public void apply(Query query) {
for (Entry entry : pathMap.entrySet()) {
@@ -179,6 +181,7 @@ public class PathProperties implements FetchPath {
return path;
}
+ @Override
public String toString() {
return propSet.toString();
}
diff --git a/src/main/java/io/ebean/text/TimeStringParser.java b/src/main/java/io/ebean/text/TimeStringParser.java
index fa185eafb..53ecab696 100644
--- a/src/main/java/io/ebean/text/TimeStringParser.java
+++ b/src/main/java/io/ebean/text/TimeStringParser.java
@@ -19,6 +19,7 @@ public final class TimeStringParser implements StringParser {
/**
* Parse the String supporting both HH:mm:ss and HH:mm formats.
*/
+ @Override
@SuppressWarnings("deprecation")
public Object parse(String value) {
if (value == null || value.trim().isEmpty()) {
diff --git a/src/main/java/io/ebean/text/csv/DefaultCsvCallback.java b/src/main/java/io/ebean/text/csv/DefaultCsvCallback.java
index 13e7f5f0e..b9c7daa46 100644
--- a/src/main/java/io/ebean/text/csv/DefaultCsvCallback.java
+++ b/src/main/java/io/ebean/text/csv/DefaultCsvCallback.java
@@ -77,6 +77,7 @@ public class DefaultCsvCallback implements CsvCallback {
/**
* Create a transaction if required.
*/
+ @Override
public void begin(EbeanServer server) {
this.server = server;
this.startTime = System.currentTimeMillis();
@@ -92,6 +93,7 @@ public class DefaultCsvCallback implements CsvCallback {
*
* By default this does nothing (effectively ignoring the heading).
*/
+ @Override
public void readHeader(String[] line) {
}
@@ -109,6 +111,7 @@ public class DefaultCsvCallback implements CsvCallback {
* error).
*
*/
+ @Override
public boolean processLine(int row, String[] line) {
return true;
}
@@ -121,6 +124,7 @@ public class DefaultCsvCallback implements CsvCallback {
* to use Cascade.PERSIST etc).
*
*/
+ @Override
public void processBean(int row, String[] line, T bean) {
// assumes single bean or Cascade.PERSIST will save any
@@ -135,6 +139,7 @@ public class DefaultCsvCallback implements CsvCallback {
/**
* Commit the transaction if one was created.
*/
+ @Override
public void end(int row) {
commitTransactionIfCreated();
@@ -146,6 +151,7 @@ public class DefaultCsvCallback implements CsvCallback {
/**
* Rollback the transaction if one was created.
*/
+ @Override
public void endWithError(int row, Exception e) {
rollbackTransactionIfCreated(e);
}
diff --git a/src/main/java/io/ebean/text/json/EJsonReader.java b/src/main/java/io/ebean/text/json/EJsonReader.java
index edf6652b6..9b00ed67f 100644
--- a/src/main/java/io/ebean/text/json/EJsonReader.java
+++ b/src/main/java/io/ebean/text/json/EJsonReader.java
@@ -304,22 +304,27 @@ class EJsonReader {
map = new ModifyAwareMap<>(owner, new LinkedHashMap<>());
}
+ @Override
public void popContext(Context temp) {
setValue(temp.getValue());
}
+ @Override
Object getValue() {
return map;
}
+ @Override
void setKey(String key) {
this.key = key;
}
+ @Override
void setValue(Object value) {
map.put(key, value);
}
+ @Override
void setValueNull() {
map.put(key, null);
}
@@ -337,22 +342,27 @@ class EJsonReader {
values = new ModifyAwareList<>(owner, new ArrayList<>());
}
+ @Override
public void popContext(Context temp) {
values.add(temp.getValue());
}
+ @Override
Object getValue() {
return values;
}
+ @Override
void setValue(Object value) {
values.add(value);
}
+ @Override
void setValueNull() {
// ignore
}
+ @Override
void setKey(String key) {
// not expected
}
diff --git a/src/main/java/io/ebeaninternal/api/BindParams.java b/src/main/java/io/ebeaninternal/api/BindParams.java
index 9b848bc3c..2bd9e3515 100644
--- a/src/main/java/io/ebeaninternal/api/BindParams.java
+++ b/src/main/java/io/ebeaninternal/api/BindParams.java
@@ -397,6 +397,7 @@ public class BindParams implements Serializable {
return copy;
}
+ @Override
public int hashCode() {
int hc = getClass().hashCode();
hc = hc * 92821 + (isInParam ? 0 : 1);
@@ -406,6 +407,7 @@ public class BindParams implements Serializable {
return hc;
}
+ @Override
public boolean equals(Object o) {
return o != null && (o == this || (o instanceof Param) && hashCode() == o.hashCode());
}
diff --git a/src/main/java/io/ebeaninternal/api/HashQuery.java b/src/main/java/io/ebeaninternal/api/HashQuery.java
index e58ff8226..c14cb88d7 100644
--- a/src/main/java/io/ebeaninternal/api/HashQuery.java
+++ b/src/main/java/io/ebeaninternal/api/HashQuery.java
@@ -17,16 +17,19 @@ public class HashQuery {
this.bindHash = bindHash;
}
+ @Override
public String toString() {
return "HashQuery@" + Integer.toHexString(hashCode());
}
+ @Override
public int hashCode() {
int hc = 92821 * planHash.hashCode();
hc = 92821 * hc + bindHash;
return hc;
}
+ @Override
public boolean equals(Object obj) {
if (obj == this) {
return true;
diff --git a/src/main/java/io/ebeaninternal/api/HashQueryPlan.java b/src/main/java/io/ebeaninternal/api/HashQueryPlan.java
index 879592088..49cfb755d 100644
--- a/src/main/java/io/ebeaninternal/api/HashQueryPlan.java
+++ b/src/main/java/io/ebeaninternal/api/HashQueryPlan.java
@@ -17,6 +17,7 @@ public class HashQueryPlan {
this.bindCount = bindCount;
}
+ @Override
public String toString() {
return planHash + ":" + bindCount + (rawSql != null ? ":r" : "");
}
@@ -30,6 +31,7 @@ public class HashQueryPlan {
return planHash + "_" + bindCount;
}
+ @Override
public int hashCode() {
int hc = planHash;
hc = hc * 92821 + bindCount;
@@ -37,6 +39,7 @@ public class HashQueryPlan {
return hc;
}
+ @Override
public boolean equals(Object obj) {
if (obj == this) {
return true;
diff --git a/src/main/java/io/ebeaninternal/api/HashQueryPlanBuilder.java b/src/main/java/io/ebeaninternal/api/HashQueryPlanBuilder.java
index be337d202..71ccb9f36 100644
--- a/src/main/java/io/ebeaninternal/api/HashQueryPlanBuilder.java
+++ b/src/main/java/io/ebeaninternal/api/HashQueryPlanBuilder.java
@@ -15,6 +15,7 @@ public class HashQueryPlanBuilder {
this.planHash = 92821;
}
+ @Override
public String toString() {
return planHash + ":" + bindCount;
}
diff --git a/src/main/java/io/ebeaninternal/api/ScopeTrans.java b/src/main/java/io/ebeaninternal/api/ScopeTrans.java
index 0f4f1f390..cca956d60 100644
--- a/src/main/java/io/ebeaninternal/api/ScopeTrans.java
+++ b/src/main/java/io/ebeaninternal/api/ScopeTrans.java
@@ -105,6 +105,7 @@ public class ScopeTrans implements Thread.UncaughtExceptionHandler {
* Called when the Thread catches any uncaught exception.
* For example, an unexpected NullPointerException or Error.
*/
+ @Override
public void uncaughtException(Thread thread, Throwable e) {
// rollback transaction if required
diff --git a/src/main/java/io/ebeaninternal/api/SpiQuery.java b/src/main/java/io/ebeaninternal/api/SpiQuery.java
index 5dd405414..8f8f6fb27 100644
--- a/src/main/java/io/ebeaninternal/api/SpiQuery.java
+++ b/src/main/java/io/ebeaninternal/api/SpiQuery.java
@@ -275,6 +275,7 @@ public interface SpiQuery extends Query {
/**
* Return a copy of the query.
*/
+ @Override
SpiQuery copy();
/**
@@ -650,11 +651,13 @@ public interface SpiQuery extends Query {
/**
* Return the maximum number of rows to return in the query.
*/
+ @Override
int getMaxRows();
/**
* Return the index of the first row to return in the query.
*/
+ @Override
int getFirstRow();
/**
diff --git a/src/main/java/io/ebeaninternal/api/SpiUpdate.java b/src/main/java/io/ebeaninternal/api/SpiUpdate.java
index 613e1f592..ebe8e5ab8 100644
--- a/src/main/java/io/ebeaninternal/api/SpiUpdate.java
+++ b/src/main/java/io/ebeaninternal/api/SpiUpdate.java
@@ -12,21 +12,25 @@ public interface SpiUpdate extends Update {
*/
enum OrmUpdateType {
INSERT {
+ @Override
public String toString() {
return "Insert";
}
},
UPDATE {
+ @Override
public String toString() {
return "Update";
}
},
DELETE {
+ @Override
public String toString() {
return "Delete";
}
},
UNKNOWN {
+ @Override
public String toString() {
return "Unknown";
}
diff --git a/src/main/java/io/ebeaninternal/api/TransactionEventTable.java b/src/main/java/io/ebeaninternal/api/TransactionEventTable.java
index 17a884b89..cde507c1a 100644
--- a/src/main/java/io/ebeaninternal/api/TransactionEventTable.java
+++ b/src/main/java/io/ebeaninternal/api/TransactionEventTable.java
@@ -18,6 +18,7 @@ public final class TransactionEventTable implements Serializable {
private final Map map = new HashMap<>();
+ @Override
public String toString() {
return "TransactionEventTable " + map.values();
}
@@ -105,6 +106,7 @@ public final class TransactionEventTable implements Serializable {
msgList.add(msg);
}
+ @Override
public String toString() {
return "TableIUD " + table + " i:" + insert + " u:" + update + " d:" + delete;
}
@@ -121,18 +123,22 @@ public final class TransactionEventTable implements Serializable {
}
}
+ @Override
public String getTableName() {
return table;
}
+ @Override
public boolean isInsert() {
return insert;
}
+ @Override
public boolean isUpdate() {
return update;
}
+ @Override
public boolean isDelete() {
return delete;
}
diff --git a/src/main/java/io/ebeaninternal/server/autotune/AutoTuneService.java b/src/main/java/io/ebeaninternal/server/autotune/AutoTuneService.java
index 05fd5d128..047eb9e08 100644
--- a/src/main/java/io/ebeaninternal/server/autotune/AutoTuneService.java
+++ b/src/main/java/io/ebeaninternal/server/autotune/AutoTuneService.java
@@ -34,6 +34,7 @@ public interface AutoTuneService extends AutoTune {
* Fire a garbage collection (hint to the JVM). Assuming garbage collection
* fires this will gather the usage profiling information.
*/
+ @Override
void collectProfiling();
/**
diff --git a/src/main/java/io/ebeaninternal/server/autotune/service/DefaultAutoTuneService.java b/src/main/java/io/ebeaninternal/server/autotune/service/DefaultAutoTuneService.java
index 9e71ec617..a9c49bcb3 100644
--- a/src/main/java/io/ebeaninternal/server/autotune/service/DefaultAutoTuneService.java
+++ b/src/main/java/io/ebeaninternal/server/autotune/service/DefaultAutoTuneService.java
@@ -235,6 +235,7 @@ public class DefaultAutoTuneService implements AutoTuneService {
* to the existing tuning.
*
*/
+ @Override
public void reportProfiling() {
saveProfilingOnShutdown(false);
}
diff --git a/src/main/java/io/ebeaninternal/server/autotune/service/ProfileManager.java b/src/main/java/io/ebeaninternal/server/autotune/service/ProfileManager.java
index ee93cc1ce..030bf205a 100644
--- a/src/main/java/io/ebeaninternal/server/autotune/service/ProfileManager.java
+++ b/src/main/java/io/ebeaninternal/server/autotune/service/ProfileManager.java
@@ -75,6 +75,7 @@ public class ProfileManager implements ProfilingListener {
* query in which case the parentNode will be null, or a lazy loading query
* resulting from traversal of the object graph.
*/
+ @Override
public void collectQueryInfo(ObjectGraphNode node, long beans, long micros) {
if (node != null) {
@@ -93,6 +94,7 @@ public class ProfileManager implements ProfilingListener {
* is called on the bean.
*
*/
+ @Override
public void collectNodeUsage(NodeUsageCollector usageCollector) {
ProfileOrigin profileOrigin = getProfileOrigin(usageCollector.getNode().getOriginQueryPoint());
diff --git a/src/main/java/io/ebeaninternal/server/autotune/service/ProfileOriginNodeUsage.java b/src/main/java/io/ebeaninternal/server/autotune/service/ProfileOriginNodeUsage.java
index e19e8703f..6bbf32ce2 100644
--- a/src/main/java/io/ebeaninternal/server/autotune/service/ProfileOriginNodeUsage.java
+++ b/src/main/java/io/ebeaninternal/server/autotune/service/ProfileOriginNodeUsage.java
@@ -107,6 +107,7 @@ public class ProfileOriginNodeUsage {
}
}
+ @Override
public String toString() {
return "path[" + path + "] profileCount[" + profileCount + "] used[" + profileUsedCount + "] props" + aggregateUsed;
}
diff --git a/src/main/java/io/ebeaninternal/server/autotune/service/TunedQueryInfo.java b/src/main/java/io/ebeaninternal/server/autotune/service/TunedQueryInfo.java
index f8faa0952..374a8d722 100644
--- a/src/main/java/io/ebeaninternal/server/autotune/service/TunedQueryInfo.java
+++ b/src/main/java/io/ebeaninternal/server/autotune/service/TunedQueryInfo.java
@@ -63,6 +63,7 @@ public class TunedQueryInfo implements Serializable {
return tuned;
}
+ @Override
public String toString() {
return tunedDetail.toString();
}
diff --git a/src/main/java/io/ebeaninternal/server/cache/CachedBeanData.java b/src/main/java/io/ebeaninternal/server/cache/CachedBeanData.java
index eb1b3389a..930adae21 100644
--- a/src/main/java/io/ebeaninternal/server/cache/CachedBeanData.java
+++ b/src/main/java/io/ebeaninternal/server/cache/CachedBeanData.java
@@ -72,6 +72,7 @@ public class CachedBeanData implements Externalizable {
}
}
+ @Override
public String toString() {
return data.toString();
}
diff --git a/src/main/java/io/ebeaninternal/server/cache/CachedManyIds.java b/src/main/java/io/ebeaninternal/server/cache/CachedManyIds.java
index 15fcf0d8f..155a43ff5 100644
--- a/src/main/java/io/ebeaninternal/server/cache/CachedManyIds.java
+++ b/src/main/java/io/ebeaninternal/server/cache/CachedManyIds.java
@@ -44,6 +44,7 @@ public class CachedManyIds implements Externalizable {
}
}
+ @Override
public String toString() {
return idList.toString();
}
diff --git a/src/main/java/io/ebeaninternal/server/cache/DefaultServerCache.java b/src/main/java/io/ebeaninternal/server/cache/DefaultServerCache.java
index 4ce91d4e3..5a12d19d8 100644
--- a/src/main/java/io/ebeaninternal/server/cache/DefaultServerCache.java
+++ b/src/main/java/io/ebeaninternal/server/cache/DefaultServerCache.java
@@ -344,6 +344,7 @@ public class DefaultServerCache implements ServerCache {
private static final long serialVersionUID = 1L;
+ @Override
public int compare(CacheEntry entry1, CacheEntry entry2) {
long x = entry1.getLastAccessTime();
long y = entry2.getLastAccessTime();
diff --git a/src/main/java/io/ebeaninternal/server/cache/DefaultServerCacheFactory.java b/src/main/java/io/ebeaninternal/server/cache/DefaultServerCacheFactory.java
index 23ce910b6..76ef67f71 100644
--- a/src/main/java/io/ebeaninternal/server/cache/DefaultServerCacheFactory.java
+++ b/src/main/java/io/ebeaninternal/server/cache/DefaultServerCacheFactory.java
@@ -28,6 +28,7 @@ class DefaultServerCacheFactory implements ServerCacheFactory {
this.executor = executor;
}
+ @Override
public ServerCache createCache(ServerCacheType type, String cacheKey, ServerCacheOptions cacheOptions) {
DefaultServerCache cache = new DefaultServerCache(cacheKey, cacheOptions);
diff --git a/src/main/java/io/ebeaninternal/server/cache/DefaultServerCacheManager.java b/src/main/java/io/ebeaninternal/server/cache/DefaultServerCacheManager.java
index ea399165c..09a100c69 100644
--- a/src/main/java/io/ebeaninternal/server/cache/DefaultServerCacheManager.java
+++ b/src/main/java/io/ebeaninternal/server/cache/DefaultServerCacheManager.java
@@ -34,6 +34,7 @@ public class DefaultServerCacheManager implements SpiCacheManager {
this(true, null, new DefaultServerCacheFactory(), new ServerCacheOptions(), new ServerCacheOptions());
}
+ @Override
public boolean isLocalL2Caching() {
return localL2Caching;
}
@@ -41,14 +42,17 @@ public class DefaultServerCacheManager implements SpiCacheManager {
/**
* Clear all caches.
*/
+ @Override
public void clearAll() {
cacheHolder.clearAll();
}
+ @Override
public Supplier getCollectionIdsCache(Class> beanType, String propertyName) {
return cacheHolder.getCache(beanType, name(beanType) + "." + propertyName, ServerCacheType.COLLECTION_IDS);
}
+ @Override
public Supplier getNaturalKeyCache(Class> beanType) {
return cacheHolder.getCache(beanType, name(beanType), ServerCacheType.NATURAL_KEY);
}
@@ -56,6 +60,7 @@ public class DefaultServerCacheManager implements SpiCacheManager {
/**
* Return the query cache for a given bean type.
*/
+ @Override
public Supplier getQueryCache(Class> beanType) {
return cacheHolder.getCache(beanType, name(beanType), ServerCacheType.QUERY);
}
@@ -63,6 +68,7 @@ public class DefaultServerCacheManager implements SpiCacheManager {
/**
* Return the bean cache for a given bean type.
*/
+ @Override
public Supplier getBeanCache(Class> beanType) {
return cacheHolder.getCache(beanType, name(beanType), ServerCacheType.BEAN);
}
diff --git a/src/main/java/io/ebeaninternal/server/core/CObjectGraphNodeStatistics.java b/src/main/java/io/ebeaninternal/server/core/CObjectGraphNodeStatistics.java
index 2fbfaa9be..eb4aa2a16 100644
--- a/src/main/java/io/ebeaninternal/server/core/CObjectGraphNodeStatistics.java
+++ b/src/main/java/io/ebeaninternal/server/core/CObjectGraphNodeStatistics.java
@@ -56,6 +56,7 @@ public class CObjectGraphNodeStatistics {
this.totalBeans = totalBeans;
}
+ @Override
public String toString() {
return node + " count[" + count + "] time[" + totalTime + "] beans[" + totalBeans + "]";
}
diff --git a/src/main/java/io/ebeaninternal/server/core/DefaultBackgroundExecutor.java b/src/main/java/io/ebeaninternal/server/core/DefaultBackgroundExecutor.java
index 7cd0b1500..3e1b94d93 100644
--- a/src/main/java/io/ebeaninternal/server/core/DefaultBackgroundExecutor.java
+++ b/src/main/java/io/ebeaninternal/server/core/DefaultBackgroundExecutor.java
@@ -26,14 +26,17 @@ public class DefaultBackgroundExecutor implements SpiBackgroundExecutor {
/**
* Execute a Runnable using a background thread.
*/
+ @Override
public void execute(Runnable r) {
pool.execute(r);
}
+ @Override
public void executePeriodically(Runnable r, long delay, TimeUnit unit) {
schedulePool.scheduleWithFixedDelay(r, delay, delay, unit);
}
+ @Override
public void shutdown() {
pool.shutdown();
schedulePool.shutdown();
diff --git a/src/main/java/io/ebeaninternal/server/core/DefaultBeanState.java b/src/main/java/io/ebeaninternal/server/core/DefaultBeanState.java
index b211c9159..22500ff17 100644
--- a/src/main/java/io/ebeaninternal/server/core/DefaultBeanState.java
+++ b/src/main/java/io/ebeaninternal/server/core/DefaultBeanState.java
@@ -23,54 +23,67 @@ public class DefaultBeanState implements BeanState {
this.intercept = entityBean._ebean_getIntercept();
}
+ @Override
public void setPropertyLoaded(String propertyName, boolean loaded) {
intercept.setPropertyLoaded(propertyName, loaded);
}
+ @Override
public boolean isReference() {
return intercept.isReference();
}
+ @Override
public boolean isNew() {
return intercept.isNew();
}
+ @Override
public boolean isNewOrDirty() {
return intercept.isNewOrDirty();
}
+ @Override
public boolean isDirty() {
return intercept.isDirty();
}
+ @Override
public Set getLoadedProps() {
return intercept.getLoadedPropertyNames();
}
+ @Override
public Set getChangedProps() {
return intercept.getDirtyPropertyNames();
}
+ @Override
public Map getDirtyValues() {
return intercept.getDirtyValues();
}
+ @Override
public boolean isReadOnly() {
return intercept.isReadOnly();
}
+ @Override
public void setReadOnly(boolean readOnly) {
intercept.setReadOnly(readOnly);
}
+ @Override
public void addPropertyChangeListener(PropertyChangeListener listener) {
entityBean.addPropertyChangeListener(listener);
}
+ @Override
public void removePropertyChangeListener(PropertyChangeListener listener) {
entityBean.removePropertyChangeListener(listener);
}
+ @Override
public void setLoaded() {
intercept.setLoaded();
}
diff --git a/src/main/java/io/ebeaninternal/server/core/DefaultCallableSql.java b/src/main/java/io/ebeaninternal/server/core/DefaultCallableSql.java
index 60bd0e16a..f41919ce2 100644
--- a/src/main/java/io/ebeaninternal/server/core/DefaultCallableSql.java
+++ b/src/main/java/io/ebeaninternal/server/core/DefaultCallableSql.java
@@ -50,57 +50,69 @@ public class DefaultCallableSql implements Serializable, SpiCallableSql {
server.execute(this, null);
}
+ @Override
public String getLabel() {
return label;
}
+ @Override
public CallableSql setLabel(String label) {
this.label = label;
return this;
}
+ @Override
public int getTimeout() {
return timeout;
}
+ @Override
public String getSql() {
return sql;
}
+ @Override
public CallableSql setTimeout(int secs) {
this.timeout = secs;
return this;
}
+ @Override
public CallableSql setSql(String sql) {
this.sql = sql;
return this;
}
+ @Override
public CallableSql bind(int position, Object value) {
bindParameters.setParameter(position, value);
return this;
}
+ @Override
public CallableSql setParameter(int position, Object value) {
bindParameters.setParameter(position, value);
return this;
}
+ @Override
public CallableSql registerOut(int position, int type) {
bindParameters.registerOut(position, type);
return this;
}
+ @Override
public Object getObject(int position) {
Param p = bindParameters.getParameter(position);
return p.getOutValue();
}
+ @Override
public boolean executeOverride(CallableStatement cstmt) throws SQLException {
return false;
}
+ @Override
public CallableSql addModification(String tableName, boolean inserts, boolean updates, boolean deletes) {
transactionEvent.add(tableName, inserts, updates, deletes);
@@ -112,10 +124,12 @@ public class DefaultCallableSql implements Serializable, SpiCallableSql {
* information for this CallableSql. This information is merged into the
* transaction after the transaction is commited.
*/
+ @Override
public TransactionEventTable getTransactionEventTable() {
return transactionEvent;
}
+ @Override
public BindParams getBindParams() {
return bindParameters;
}
diff --git a/src/main/java/io/ebeaninternal/server/core/DefaultContainer.java b/src/main/java/io/ebeaninternal/server/core/DefaultContainer.java
index 717112ad1..4f686a404 100644
--- a/src/main/java/io/ebeaninternal/server/core/DefaultContainer.java
+++ b/src/main/java/io/ebeaninternal/server/core/DefaultContainer.java
@@ -59,6 +59,7 @@ public class DefaultContainer implements SpiContainer {
ShutdownManager.registerContainer(this);
}
+ @Override
public void shutdown() {
clusterManager.shutdown();
}
@@ -66,6 +67,7 @@ public class DefaultContainer implements SpiContainer {
/**
* Create the server reading configuration information from ebean.properties.
*/
+ @Override
public SpiEbeanServer createServer(String name) {
ServerConfig config = new ServerConfig();
@@ -89,6 +91,7 @@ public class DefaultContainer implements SpiContainer {
/**
* Create the implementation from the configuration.
*/
+ @Override
public SpiEbeanServer createServer(ServerConfig serverConfig) {
synchronized (this) {
diff --git a/src/main/java/io/ebeaninternal/server/core/DefaultMetaInfoManager.java b/src/main/java/io/ebeaninternal/server/core/DefaultMetaInfoManager.java
index cf454f3cd..f1ceb982f 100644
--- a/src/main/java/io/ebeaninternal/server/core/DefaultMetaInfoManager.java
+++ b/src/main/java/io/ebeaninternal/server/core/DefaultMetaInfoManager.java
@@ -40,6 +40,7 @@ public class DefaultMetaInfoManager implements MetaInfoManager {
return list;
}
+ @Override
public List collectNodeStatistics(boolean reset) {
List list = new ArrayList<>();
diff --git a/src/main/java/io/ebeaninternal/server/core/DefaultServer.java b/src/main/java/io/ebeaninternal/server/core/DefaultServer.java
index 6c3ff080f..102d63290 100644
--- a/src/main/java/io/ebeaninternal/server/core/DefaultServer.java
+++ b/src/main/java/io/ebeaninternal/server/core/DefaultServer.java
@@ -303,6 +303,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
return updateAllPropertiesInBatch;
}
+ @Override
public int getLazyLoadBatchSize() {
return lazyLoadBatchSize;
}
@@ -316,10 +317,12 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
return currentTenantProvider.currentId();
}
+ @Override
public ServerConfig getServerConfig() {
return serverConfig;
}
+ @Override
public DatabasePlatform getDatabasePlatform() {
return databasePlatform;
}
@@ -339,10 +342,12 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
return this;
}
+ @Override
public BackgroundExecutor getBackgroundExecutor() {
return backgroundExecutor;
}
+ @Override
public ExpressionFactory getExpressionFactory() {
return expressionFactory;
}
@@ -388,6 +393,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
/**
* Shutting down via JVM Shutdown hook.
*/
+ @Override
public void shutdownManaged() {
synchronized (this) {
shutdownInternal(true, false);
@@ -397,6 +403,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
/**
* Shutting down manually.
*/
+ @Override
public void shutdown(boolean shutdownDataSource, boolean deregisterDriver) {
synchronized (this) {
// Unregister from JVM Shutdown hook
@@ -443,10 +450,12 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
/**
* Return the server name.
*/
+ @Override
public String getName() {
return serverName;
}
+ @Override
public BeanState getBeanState(Object bean) {
if (bean instanceof EntityBean) {
return new DefaultBeanState((EntityBean) bean);
@@ -458,46 +467,55 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
/**
* Compile a query. Only valid for ORM queries.
*/
+ @Override
public CQuery compileQuery(Query query, Transaction t) {
SpiOrmQueryRequest qr = createQueryRequest(Type.SUBQUERY, query, t);
OrmQueryRequest orm = (OrmQueryRequest) qr;
return cqueryEngine.buildQuery(orm);
}
+ @Override
public ServerCacheManager getServerCacheManager() {
return serverCacheManager;
}
+ @Override
public void refreshMany(Object parentBean, String propertyName) {
beanLoader.refreshMany(checkEntityBean(parentBean), propertyName);
}
+ @Override
public void loadMany(LoadManyRequest loadRequest) {
beanLoader.loadMany(loadRequest);
}
+ @Override
public void loadMany(BeanCollection> bc, boolean onlyIds) {
beanLoader.loadMany(bc, onlyIds);
}
+ @Override
public void refresh(Object bean) {
beanLoader.refresh(checkEntityBean(bean));
}
+ @Override
public void loadBean(LoadBeanRequest loadRequest) {
beanLoader.loadBean(loadRequest);
}
+ @Override
public void loadBean(EntityBeanIntercept ebi) {
beanLoader.loadBean(ebi);
}
+ @Override
public Map diff(Object a, Object b) {
if (a == null) {
return null;
@@ -516,6 +534,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
* to maintain its cache and text indexes appropriately.
*
*/
+ @Override
public void externalModification(TransactionEventTable tableEvent) {
SpiTransaction t = transactionScopeManager.get();
if (t != null) {
@@ -529,6 +548,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
* Developer informing eBean that tables where modified outside of eBean.
* Invalidate the cache etc as required.
*/
+ @Override
public void externalModification(String tableName, boolean inserts, boolean updates, boolean deletes) {
TransactionEventTable evt = new TransactionEventTable();
@@ -540,6 +560,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
/**
* Clear the query execution statistics.
*/
+ @Override
public void clearQueryStatistics() {
for (BeanDescriptor> desc : getBeanDescriptors()) {
desc.clearQueryStatistics();
@@ -554,6 +575,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
* bean is typically an instance of a dynamically generated class.
*
*/
+ @Override
@SuppressWarnings("unchecked")
public T createEntityBean(Class type) {
BeanDescriptor desc = getBeanDescriptor(type);
@@ -568,6 +590,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
* then it will returned that object.
*
*/
+ @Override
@SuppressWarnings({"unchecked", "rawtypes"})
public T getReference(Class type, Object id) {
@@ -616,6 +639,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
* Creates a new Transaction that is NOT stored in TransactionThreadLocal. Use
* this when you want a thread to have a second independent transaction.
*/
+ @Override
public Transaction createTransaction() {
return transactionManager.createTransaction(true, -1);
@@ -627,15 +651,18 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
* Note that this transaction is not stored in a thread local.
*
*/
+ @Override
public Transaction createTransaction(TxIsolation isolation) {
return transactionManager.createTransaction(true, isolation.getLevel());
}
+ @Override
public T execute(TxCallable c) {
return execute(null, c);
}
+ @Override
public T execute(TxScope scope, TxCallable c) {
ScopeTrans scopeTrans = createScopeTrans(scope);
try {
@@ -652,10 +679,12 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
}
}
+ @Override
public void execute(TxRunnable r) {
execute(null, r);
}
+ @Override
public void execute(TxScope scope, TxRunnable r) {
ScopeTrans scopeTrans = createScopeTrans(scope);
try {
@@ -711,6 +740,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
}
}
+ @Override
public ScopeTrans createScopeTrans(TxScope txScope) {
if (txScope == null) {
@@ -762,6 +792,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
/**
* Returns the current transaction (or null) from the scope.
*/
+ @Override
public SpiTransaction getCurrentServerTransaction() {
return transactionScopeManager.get();
}
@@ -775,10 +806,12 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
* Note that the transaction is stored in a ThreadLocal variable.
*
*/
+ @Override
public Transaction beginTransaction() {
return beginTransaction(TxScope.required());
}
+ @Override
public Transaction beginTransaction(TxScope scope) {
ScopeTrans scopeTrans = createScopeTrans(scope);
return new ScopedTransaction(scopeTrans);
@@ -790,6 +823,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
* Note that the transaction is stored in a ThreadLocal variable.
*
*/
+ @Override
public Transaction beginTransaction(TxIsolation isolation) {
// start an explicit transaction
SpiTransaction t = transactionManager.createTransaction(true, isolation.getLevel());
@@ -801,6 +835,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
* Return the current transaction or null if there is not one currently in
* scope.
*/
+ @Override
public Transaction currentTransaction() {
return transactionScopeManager.get();
}
@@ -808,6 +843,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
/**
* Commit the current transaction.
*/
+ @Override
public void commitTransaction() {
transactionScopeManager.commit();
}
@@ -815,6 +851,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
/**
* Rollback the current transaction.
*/
+ @Override
public void rollbackTransaction() {
transactionScopeManager.rollback();
}
@@ -847,6 +884,7 @@ public final class DefaultServer implements SpiServer, SpiEbeanServer {
*