diff --git a/README.md b/README.md index 8c181bf95..bd914564e 100644 --- a/README.md +++ b/README.md @@ -1,7 +1,7 @@ [![Build Status](https://travis-ci.org/debezium/debezium.svg?branch=master)](https://travis-ci.org/debezium/debezium) [![License](http://img.shields.io/:license-apache-brightgreen.svg)](http://www.apache.org/licenses/LICENSE-2.0.html) -Copyright 2008-2016 Debezium Authors. Licensed under the [Apache License, Version 2.0](http://www.apache.org/licenses/LICENSE-2.0). +Copyright Debezium Authors. Licensed under the [Apache License, Version 2.0](http://www.apache.org/licenses/LICENSE-2.0). # Debezium diff --git a/debezium-core/src/main/java/io/debezium/config/Configuration.java b/debezium-core/src/main/java/io/debezium/config/Configuration.java index 2387997ba..7b6b91f69 100644 --- a/debezium-core/src/main/java/io/debezium/config/Configuration.java +++ b/debezium-core/src/main/java/io/debezium/config/Configuration.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/crdt/CRDT.java b/debezium-core/src/main/java/io/debezium/crdt/CRDT.java index 79e0117f8..c8fb071c8 100644 --- a/debezium-core/src/main/java/io/debezium/crdt/CRDT.java +++ b/debezium-core/src/main/java/io/debezium/crdt/CRDT.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/crdt/Count.java b/debezium-core/src/main/java/io/debezium/crdt/Count.java index b429d6358..b8aaf109f 100644 --- a/debezium-core/src/main/java/io/debezium/crdt/Count.java +++ b/debezium-core/src/main/java/io/debezium/crdt/Count.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/crdt/DeltaCount.java b/debezium-core/src/main/java/io/debezium/crdt/DeltaCount.java index 6023aec9d..953d50ab1 100644 --- a/debezium-core/src/main/java/io/debezium/crdt/DeltaCount.java +++ b/debezium-core/src/main/java/io/debezium/crdt/DeltaCount.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/crdt/DeltaCounter.java b/debezium-core/src/main/java/io/debezium/crdt/DeltaCounter.java index f543b4fb8..171a254b9 100644 --- a/debezium-core/src/main/java/io/debezium/crdt/DeltaCounter.java +++ b/debezium-core/src/main/java/io/debezium/crdt/DeltaCounter.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/crdt/GCount.java b/debezium-core/src/main/java/io/debezium/crdt/GCount.java index 0b3b1d118..2e5f29078 100644 --- a/debezium-core/src/main/java/io/debezium/crdt/GCount.java +++ b/debezium-core/src/main/java/io/debezium/crdt/GCount.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/crdt/GCounter.java b/debezium-core/src/main/java/io/debezium/crdt/GCounter.java index 9f3585cbb..77ccb6385 100644 --- a/debezium-core/src/main/java/io/debezium/crdt/GCounter.java +++ b/debezium-core/src/main/java/io/debezium/crdt/GCounter.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/crdt/PNCount.java b/debezium-core/src/main/java/io/debezium/crdt/PNCount.java index 1f3db346d..f52ff1447 100644 --- a/debezium-core/src/main/java/io/debezium/crdt/PNCount.java +++ b/debezium-core/src/main/java/io/debezium/crdt/PNCount.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/crdt/PNCounter.java b/debezium-core/src/main/java/io/debezium/crdt/PNCounter.java index 7a1c8a3a9..1afcc4505 100644 --- a/debezium-core/src/main/java/io/debezium/crdt/PNCounter.java +++ b/debezium-core/src/main/java/io/debezium/crdt/PNCounter.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/crdt/StateBasedGCounter.java b/debezium-core/src/main/java/io/debezium/crdt/StateBasedGCounter.java index 76cd78ff2..d9729f49d 100644 --- a/debezium-core/src/main/java/io/debezium/crdt/StateBasedGCounter.java +++ b/debezium-core/src/main/java/io/debezium/crdt/StateBasedGCounter.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/crdt/StateBasedPNCounter.java b/debezium-core/src/main/java/io/debezium/crdt/StateBasedPNCounter.java index b60ba04d6..a0184a12a 100644 --- a/debezium-core/src/main/java/io/debezium/crdt/StateBasedPNCounter.java +++ b/debezium-core/src/main/java/io/debezium/crdt/StateBasedPNCounter.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/crdt/StateBasedPNDeltaCounter.java b/debezium-core/src/main/java/io/debezium/crdt/StateBasedPNDeltaCounter.java index b68f1035b..cac664f60 100644 --- a/debezium-core/src/main/java/io/debezium/crdt/StateBasedPNDeltaCounter.java +++ b/debezium-core/src/main/java/io/debezium/crdt/StateBasedPNDeltaCounter.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/data/Bits.java b/debezium-core/src/main/java/io/debezium/data/Bits.java index 3b75d543b..2027f7008 100644 --- a/debezium-core/src/main/java/io/debezium/data/Bits.java +++ b/debezium-core/src/main/java/io/debezium/data/Bits.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/data/IsoTime.java b/debezium-core/src/main/java/io/debezium/data/IsoTime.java index 833b92583..effb86238 100644 --- a/debezium-core/src/main/java/io/debezium/data/IsoTime.java +++ b/debezium-core/src/main/java/io/debezium/data/IsoTime.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/data/IsoTimestamp.java b/debezium-core/src/main/java/io/debezium/data/IsoTimestamp.java index 2fffff071..7f1106eca 100644 --- a/debezium-core/src/main/java/io/debezium/data/IsoTimestamp.java +++ b/debezium-core/src/main/java/io/debezium/data/IsoTimestamp.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/function/BooleanConsumer.java b/debezium-core/src/main/java/io/debezium/function/BooleanConsumer.java index ad409d9d9..1b15259a1 100644 --- a/debezium-core/src/main/java/io/debezium/function/BooleanConsumer.java +++ b/debezium-core/src/main/java/io/debezium/function/BooleanConsumer.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/function/Callable.java b/debezium-core/src/main/java/io/debezium/function/Callable.java index 66f45148e..cd98be140 100644 --- a/debezium-core/src/main/java/io/debezium/function/Callable.java +++ b/debezium-core/src/main/java/io/debezium/function/Callable.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/function/Predicates.java b/debezium-core/src/main/java/io/debezium/function/Predicates.java index b4b21b076..d9ea2149c 100644 --- a/debezium-core/src/main/java/io/debezium/function/Predicates.java +++ b/debezium-core/src/main/java/io/debezium/function/Predicates.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/jdbc/JdbcConfiguration.java b/debezium-core/src/main/java/io/debezium/jdbc/JdbcConfiguration.java index f0c7c7441..e05663621 100644 --- a/debezium-core/src/main/java/io/debezium/jdbc/JdbcConfiguration.java +++ b/debezium-core/src/main/java/io/debezium/jdbc/JdbcConfiguration.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/jdbc/JdbcConnection.java b/debezium-core/src/main/java/io/debezium/jdbc/JdbcConnection.java index 349366eed..582806c36 100644 --- a/debezium-core/src/main/java/io/debezium/jdbc/JdbcConnection.java +++ b/debezium-core/src/main/java/io/debezium/jdbc/JdbcConnection.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/relational/Column.java b/debezium-core/src/main/java/io/debezium/relational/Column.java index 0023d7933..3bba00242 100644 --- a/debezium-core/src/main/java/io/debezium/relational/Column.java +++ b/debezium-core/src/main/java/io/debezium/relational/Column.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/relational/ColumnEditor.java b/debezium-core/src/main/java/io/debezium/relational/ColumnEditor.java index 5b74c202e..68a8e13db 100644 --- a/debezium-core/src/main/java/io/debezium/relational/ColumnEditor.java +++ b/debezium-core/src/main/java/io/debezium/relational/ColumnEditor.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/relational/ColumnEditorImpl.java b/debezium-core/src/main/java/io/debezium/relational/ColumnEditorImpl.java index 7dfeb449b..c0be7f9e2 100644 --- a/debezium-core/src/main/java/io/debezium/relational/ColumnEditorImpl.java +++ b/debezium-core/src/main/java/io/debezium/relational/ColumnEditorImpl.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/relational/ColumnImpl.java b/debezium-core/src/main/java/io/debezium/relational/ColumnImpl.java index 9deeeda79..a7241abb9 100644 --- a/debezium-core/src/main/java/io/debezium/relational/ColumnImpl.java +++ b/debezium-core/src/main/java/io/debezium/relational/ColumnImpl.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/relational/Table.java b/debezium-core/src/main/java/io/debezium/relational/Table.java index 42866c949..ce9f9c0d1 100644 --- a/debezium-core/src/main/java/io/debezium/relational/Table.java +++ b/debezium-core/src/main/java/io/debezium/relational/Table.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/relational/TableEditor.java b/debezium-core/src/main/java/io/debezium/relational/TableEditor.java index 27c19ccd7..2a9b06023 100644 --- a/debezium-core/src/main/java/io/debezium/relational/TableEditor.java +++ b/debezium-core/src/main/java/io/debezium/relational/TableEditor.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/relational/TableEditorImpl.java b/debezium-core/src/main/java/io/debezium/relational/TableEditorImpl.java index 5e8d9a16d..544734cc9 100644 --- a/debezium-core/src/main/java/io/debezium/relational/TableEditorImpl.java +++ b/debezium-core/src/main/java/io/debezium/relational/TableEditorImpl.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/relational/TableId.java b/debezium-core/src/main/java/io/debezium/relational/TableId.java index 6a8c4dea1..f1921f7d1 100644 --- a/debezium-core/src/main/java/io/debezium/relational/TableId.java +++ b/debezium-core/src/main/java/io/debezium/relational/TableId.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/relational/TableImpl.java b/debezium-core/src/main/java/io/debezium/relational/TableImpl.java index 2757b0e37..d88b996a2 100644 --- a/debezium-core/src/main/java/io/debezium/relational/TableImpl.java +++ b/debezium-core/src/main/java/io/debezium/relational/TableImpl.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/relational/TableSchema.java b/debezium-core/src/main/java/io/debezium/relational/TableSchema.java index e5ac628c6..ed7f4b78f 100644 --- a/debezium-core/src/main/java/io/debezium/relational/TableSchema.java +++ b/debezium-core/src/main/java/io/debezium/relational/TableSchema.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/relational/TableSchemaBuilder.java b/debezium-core/src/main/java/io/debezium/relational/TableSchemaBuilder.java index ed8e1649c..a17988b3c 100644 --- a/debezium-core/src/main/java/io/debezium/relational/TableSchemaBuilder.java +++ b/debezium-core/src/main/java/io/debezium/relational/TableSchemaBuilder.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/relational/Tables.java b/debezium-core/src/main/java/io/debezium/relational/Tables.java index 041d05346..82dae76ee 100644 --- a/debezium-core/src/main/java/io/debezium/relational/Tables.java +++ b/debezium-core/src/main/java/io/debezium/relational/Tables.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/relational/ddl/DataType.java b/debezium-core/src/main/java/io/debezium/relational/ddl/DataType.java index 84f146308..3444d543c 100644 --- a/debezium-core/src/main/java/io/debezium/relational/ddl/DataType.java +++ b/debezium-core/src/main/java/io/debezium/relational/ddl/DataType.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ @@ -12,18 +12,20 @@ /** * An immutable representation of a data type + * * @author Randall Hauch */ @Immutable public final class DataType { - + /** * Obtain the data type for a user-defined or fully-qualified type name. + * * @param qualifiedName the fully-qualified name; may not be null * @return the data type; never null */ - public static DataType userDefinedType( String qualifiedName ) { - return new DataType(qualifiedName,qualifiedName,Types.OTHER,-1,-1,null,0); + public static DataType userDefinedType(String qualifiedName) { + return new DataType(qualifiedName, qualifiedName, Types.OTHER, -1, -1, null, 0); } private final String expression; @@ -32,44 +34,44 @@ public static DataType userDefinedType( String qualifiedName ) { private final long length; private final int scale; private final int[] arrayDimensions; - - protected DataType( String expr, String name, int jdbcType, long length, int scale, int[] arrayDimensions, int arrayDimLength ) { + + protected DataType(String expr, String name, int jdbcType, long length, int scale, int[] arrayDimensions, int arrayDimLength) { this.expression = expr; - this.name= name; + this.name = name; this.jdbcType = jdbcType; this.length = length; this.scale = scale; - if ( arrayDimensions == null || arrayDimLength == 0 ) { + if (arrayDimensions == null || arrayDimLength == 0) { this.arrayDimensions = null; } else { this.arrayDimensions = Arrays.copyOf(arrayDimensions, arrayDimLength); } } - + public String expression() { return expression; } - + public String name() { return name; } - + public int jdbcType() { return jdbcType; } - + public long length() { return length; } - + public int scale() { return scale; } - + public int[] arrayDimensions() { return arrayDimensions; } - + @Override public String toString() { return expression; diff --git a/debezium-core/src/main/java/io/debezium/relational/ddl/DataTypeGrammarParser.java b/debezium-core/src/main/java/io/debezium/relational/ddl/DataTypeGrammarParser.java index 88e11da01..7be399975 100644 --- a/debezium-core/src/main/java/io/debezium/relational/ddl/DataTypeGrammarParser.java +++ b/debezium-core/src/main/java/io/debezium/relational/ddl/DataTypeGrammarParser.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/relational/ddl/DataTypeParser.java b/debezium-core/src/main/java/io/debezium/relational/ddl/DataTypeParser.java index d1beba29a..5100fe939 100644 --- a/debezium-core/src/main/java/io/debezium/relational/ddl/DataTypeParser.java +++ b/debezium-core/src/main/java/io/debezium/relational/ddl/DataTypeParser.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ @@ -19,10 +19,14 @@ import io.debezium.text.TokenStream.Marker; /** - * A parser of SQL data types. Callers set up a parser and register patterns that describe the possible lists of tokens, and then - * can repeatedly {@link #parse(TokenStream, Consumer) parse} {@link TokenStream streams of tokens} looking for matches. + * A parser of SQL data types. Callers set up a parser and register patterns that describe the possible lists of data type tokens, + * and then repeatedly {@link #parse(TokenStream, Consumer) parse} {@link TokenStream streams of tokens} looking for matches. + *

+ * This is typically used within a {@link DdlParser} implementation to parse and identify data types appearing within a stream + * of DDL content. * * @author Randall Hauch + * @see DdlParser */ @ThreadSafe public class DataTypeParser { diff --git a/debezium-core/src/main/java/io/debezium/relational/ddl/DdlConstants.java b/debezium-core/src/main/java/io/debezium/relational/ddl/DdlConstants.java index 3a52445d7..a6d441744 100644 --- a/debezium-core/src/main/java/io/debezium/relational/ddl/DdlConstants.java +++ b/debezium-core/src/main/java/io/debezium/relational/ddl/DdlConstants.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/relational/ddl/DdlParser.java b/debezium-core/src/main/java/io/debezium/relational/ddl/DdlParser.java index 252402042..822dd2f0f 100644 --- a/debezium-core/src/main/java/io/debezium/relational/ddl/DdlParser.java +++ b/debezium-core/src/main/java/io/debezium/relational/ddl/DdlParser.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ @@ -33,6 +33,8 @@ * A parser for DDL statements. * * @author Randall Hauch + * @author Horia Chiorean + * @author Barry LaFond */ @NotThreadSafe public class DdlParser { diff --git a/debezium-core/src/main/java/io/debezium/relational/ddl/DdlParserSql2003.java b/debezium-core/src/main/java/io/debezium/relational/ddl/DdlParserSql2003.java index 5722f01c7..be84168a0 100644 --- a/debezium-core/src/main/java/io/debezium/relational/ddl/DdlParserSql2003.java +++ b/debezium-core/src/main/java/io/debezium/relational/ddl/DdlParserSql2003.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/relational/ddl/DdlTokenizer.java b/debezium-core/src/main/java/io/debezium/relational/ddl/DdlTokenizer.java index 75fb224be..55cb3ed54 100644 --- a/debezium-core/src/main/java/io/debezium/relational/ddl/DdlTokenizer.java +++ b/debezium-core/src/main/java/io/debezium/relational/ddl/DdlTokenizer.java @@ -1,5 +1,5 @@ /* - * Copyright 2012 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ @@ -13,8 +13,12 @@ import io.debezium.text.TokenStream.Tokens; /** + * A {@link Tokenizer} that is specialized for tokenizing DDL streams. + * * @author Randall Hauch - * + * @author Horia Chiorean + * @author Barry LaFond + * @author Jure Kajzer */ public class DdlTokenizer implements Tokenizer { @@ -56,7 +60,6 @@ public class DdlTokenizer implements Tokenizer { *

* Examples would be: "CREATE", "TABLE", "ALTER", "SCHEMA", "DROP", etc... *

- * see {@link DdlConstants} for the default SQL 92 representations. */ public static final int KEYWORD = 64; @@ -66,7 +69,6 @@ public class DdlTokenizer implements Tokenizer { *

* Examples would be: {"CREATE", "TABLE"} {"CREATE", "OR", "REPLACE", "VIEW"} *

- * see {@link DdlConstants} for the default SQL 92 representations. */ public static final int STATEMENT_KEY = 128; diff --git a/debezium-core/src/main/java/io/debezium/text/MultipleParsingExceptions.java b/debezium-core/src/main/java/io/debezium/text/MultipleParsingExceptions.java index e4fbaa9a6..30d8b34ea 100644 --- a/debezium-core/src/main/java/io/debezium/text/MultipleParsingExceptions.java +++ b/debezium-core/src/main/java/io/debezium/text/MultipleParsingExceptions.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/text/ParsingException.java b/debezium-core/src/main/java/io/debezium/text/ParsingException.java index c0f4af331..9d838d4a8 100644 --- a/debezium-core/src/main/java/io/debezium/text/ParsingException.java +++ b/debezium-core/src/main/java/io/debezium/text/ParsingException.java @@ -1,5 +1,5 @@ /* - * Copyright 2010 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ @@ -7,6 +7,8 @@ /** * An exception representing a problem during parsing of text. + * + * @author Randall Hauch */ public class ParsingException extends RuntimeException { diff --git a/debezium-core/src/main/java/io/debezium/text/Position.java b/debezium-core/src/main/java/io/debezium/text/Position.java index ed0d53910..d42dd672b 100644 --- a/debezium-core/src/main/java/io/debezium/text/Position.java +++ b/debezium-core/src/main/java/io/debezium/text/Position.java @@ -1,5 +1,5 @@ /* - * Copyright 2010 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ @@ -9,6 +9,8 @@ /** * A class that represents the position of a particular character in terms of the lines and columns of a character sequence. + * + * @author Randall Hauch */ @Immutable public final class Position { diff --git a/debezium-core/src/main/java/io/debezium/text/TokenStream.java b/debezium-core/src/main/java/io/debezium/text/TokenStream.java index 3f6133e4d..ee9faca78 100644 --- a/debezium-core/src/main/java/io/debezium/text/TokenStream.java +++ b/debezium-core/src/main/java/io/debezium/text/TokenStream.java @@ -1,5 +1,5 @@ /* - * Copyright 2010 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ @@ -337,6 +337,9 @@ * {@link Tokenizer}s with exactly this behavior can actually be created using the {@link #basicTokenizer(boolean)} method. So * while this very basic implementation is not meant to be used in all situations, it may be useful in some situations. *

+ * @author Randall Hauch + * @author Horia Chiorean + * @author Daniel Kelleher */ @NotThreadSafe public class TokenStream { diff --git a/debezium-core/src/main/java/io/debezium/text/XmlCharacters.java b/debezium-core/src/main/java/io/debezium/text/XmlCharacters.java index a8318c5ec..1939a8d5b 100644 --- a/debezium-core/src/main/java/io/debezium/text/XmlCharacters.java +++ b/debezium-core/src/main/java/io/debezium/text/XmlCharacters.java @@ -1,5 +1,5 @@ /* - * Copyright 2010 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ @@ -13,6 +13,8 @@ /** * A utility class for determining the validity of various XML names, per the XML 1.0 * Specification. + * + * @author Randall Hauch */ @Immutable public class XmlCharacters { diff --git a/debezium-core/src/main/java/io/debezium/util/Clock.java b/debezium-core/src/main/java/io/debezium/util/Clock.java index 3119d6e11..5afc8fe6a 100644 --- a/debezium-core/src/main/java/io/debezium/util/Clock.java +++ b/debezium-core/src/main/java/io/debezium/util/Clock.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/util/Collect.java b/debezium-core/src/main/java/io/debezium/util/Collect.java index 235f5e05d..2abfddcc9 100644 --- a/debezium-core/src/main/java/io/debezium/util/Collect.java +++ b/debezium-core/src/main/java/io/debezium/util/Collect.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/util/CommandLineOptions.java b/debezium-core/src/main/java/io/debezium/util/CommandLineOptions.java index 6716c309b..9c04729d5 100644 --- a/debezium-core/src/main/java/io/debezium/util/CommandLineOptions.java +++ b/debezium-core/src/main/java/io/debezium/util/CommandLineOptions.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/util/FunctionalReadWriteLock.java b/debezium-core/src/main/java/io/debezium/util/FunctionalReadWriteLock.java index 9fcfbf149..e4fb9884c 100644 --- a/debezium-core/src/main/java/io/debezium/util/FunctionalReadWriteLock.java +++ b/debezium-core/src/main/java/io/debezium/util/FunctionalReadWriteLock.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/util/HashCode.java b/debezium-core/src/main/java/io/debezium/util/HashCode.java index 753f55a69..36bbd66fb 100644 --- a/debezium-core/src/main/java/io/debezium/util/HashCode.java +++ b/debezium-core/src/main/java/io/debezium/util/HashCode.java @@ -1,5 +1,5 @@ /* - * Copyright 2008 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ @@ -15,10 +15,10 @@ */ @Immutable public class HashCode { - + // Prime number used in improving distribution private static final int PRIME = 103; - + /** * Compute a combined hash code from the supplied objects. This method always returns 0 if no objects are supplied. * @@ -26,9 +26,9 @@ public class HashCode { * @return the hash code */ public static int compute(Object... objects) { - return _compute(0, objects); + return computeHashCode(0, objects); } - + /** * Compute a combined hash code from the supplied objects using the supplied seed. * @@ -36,8 +36,8 @@ public static int compute(Object... objects) { * @param objects the objects that should be used to compute the hash code * @return the hash code */ - private static int _compute(int seed, - Object... objects) { + private static int computeHashCode(int seed, + Object... objects) { if (objects == null || objects.length == 0) { return seed * HashCode.PRIME; } @@ -69,8 +69,8 @@ private static int _compute(int seed, } return hc; } - + private HashCode() { } - + } \ No newline at end of file diff --git a/debezium-core/src/main/java/io/debezium/util/IoUtil.java b/debezium-core/src/main/java/io/debezium/util/IoUtil.java index 432f0edb9..377c91366 100644 --- a/debezium-core/src/main/java/io/debezium/util/IoUtil.java +++ b/debezium-core/src/main/java/io/debezium/util/IoUtil.java @@ -1,5 +1,5 @@ /* - * Copyright 2008 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ @@ -164,7 +164,7 @@ public static String read(InputStream stream) throws IOException { * reading. * * @param stream the streamed contents; may be null - * @param charset charset of the stream data; may not be null + * @param charset character set of the stream data; may not be null * @return the contents, or an empty string if the supplied stream is null * @throws IOException if there is an error reading the content */ diff --git a/debezium-core/src/main/java/io/debezium/util/Iterators.java b/debezium-core/src/main/java/io/debezium/util/Iterators.java index 097e883f8..f464a80e5 100644 --- a/debezium-core/src/main/java/io/debezium/util/Iterators.java +++ b/debezium-core/src/main/java/io/debezium/util/Iterators.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/util/Joiner.java b/debezium-core/src/main/java/io/debezium/util/Joiner.java index ae96de0a8..7c4841d12 100644 --- a/debezium-core/src/main/java/io/debezium/util/Joiner.java +++ b/debezium-core/src/main/java/io/debezium/util/Joiner.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/util/LazyReference.java b/debezium-core/src/main/java/io/debezium/util/LazyReference.java index 161b487f8..13b12de85 100644 --- a/debezium-core/src/main/java/io/debezium/util/LazyReference.java +++ b/debezium-core/src/main/java/io/debezium/util/LazyReference.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/util/MathOps.java b/debezium-core/src/main/java/io/debezium/util/MathOps.java index dde50a93b..df1777c72 100644 --- a/debezium-core/src/main/java/io/debezium/util/MathOps.java +++ b/debezium-core/src/main/java/io/debezium/util/MathOps.java @@ -1,5 +1,5 @@ /* - * Copyright 2010 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/util/NamedThreadFactory.java b/debezium-core/src/main/java/io/debezium/util/NamedThreadFactory.java index 8d5ed3cfc..1ad99c16e 100644 --- a/debezium-core/src/main/java/io/debezium/util/NamedThreadFactory.java +++ b/debezium-core/src/main/java/io/debezium/util/NamedThreadFactory.java @@ -1,5 +1,5 @@ /* - * Copyright 2010 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/util/Sequences.java b/debezium-core/src/main/java/io/debezium/util/Sequences.java index fb4e71853..a5f2d6e3f 100644 --- a/debezium-core/src/main/java/io/debezium/util/Sequences.java +++ b/debezium-core/src/main/java/io/debezium/util/Sequences.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/util/Stopwatch.java b/debezium-core/src/main/java/io/debezium/util/Stopwatch.java index 61e1c04be..3f9f904ff 100644 --- a/debezium-core/src/main/java/io/debezium/util/Stopwatch.java +++ b/debezium-core/src/main/java/io/debezium/util/Stopwatch.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/util/Stringifiable.java b/debezium-core/src/main/java/io/debezium/util/Stringifiable.java index 790aadbbf..1e84afd42 100644 --- a/debezium-core/src/main/java/io/debezium/util/Stringifiable.java +++ b/debezium-core/src/main/java/io/debezium/util/Stringifiable.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/main/java/io/debezium/util/Strings.java b/debezium-core/src/main/java/io/debezium/util/Strings.java index 50461ff48..e5b48da04 100644 --- a/debezium-core/src/main/java/io/debezium/util/Strings.java +++ b/debezium-core/src/main/java/io/debezium/util/Strings.java @@ -1,5 +1,5 @@ /* - * Copyright 2008 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ @@ -18,6 +18,7 @@ * String-related utility methods. * * @author Randall Hauch + * @author Horia Chiorean */ @ThreadSafe public final class Strings { diff --git a/debezium-core/src/test/java/io/debezium/jdbc/TestDatabase.java b/debezium-core/src/test/java/io/debezium/jdbc/TestDatabase.java index cdd1287b6..b1998d6fb 100644 --- a/debezium-core/src/test/java/io/debezium/jdbc/TestDatabase.java +++ b/debezium-core/src/test/java/io/debezium/jdbc/TestDatabase.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/test/java/io/debezium/relational/ColumnEditorTest.java b/debezium-core/src/test/java/io/debezium/relational/ColumnEditorTest.java index cc9d1f015..c84a457f3 100644 --- a/debezium-core/src/test/java/io/debezium/relational/ColumnEditorTest.java +++ b/debezium-core/src/test/java/io/debezium/relational/ColumnEditorTest.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/test/java/io/debezium/relational/TableEditorTest.java b/debezium-core/src/test/java/io/debezium/relational/TableEditorTest.java index c59e51a43..52cd36db3 100644 --- a/debezium-core/src/test/java/io/debezium/relational/TableEditorTest.java +++ b/debezium-core/src/test/java/io/debezium/relational/TableEditorTest.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/test/java/io/debezium/relational/TableSchemaBuilderTest.java b/debezium-core/src/test/java/io/debezium/relational/TableSchemaBuilderTest.java index 54e977585..d050ad0fc 100644 --- a/debezium-core/src/test/java/io/debezium/relational/TableSchemaBuilderTest.java +++ b/debezium-core/src/test/java/io/debezium/relational/TableSchemaBuilderTest.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/test/java/io/debezium/relational/TableTest.java b/debezium-core/src/test/java/io/debezium/relational/TableTest.java index d785da890..66751e5d8 100644 --- a/debezium-core/src/test/java/io/debezium/relational/TableTest.java +++ b/debezium-core/src/test/java/io/debezium/relational/TableTest.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/test/java/io/debezium/relational/ddl/DataTypeGrammarParserTest.java b/debezium-core/src/test/java/io/debezium/relational/ddl/DataTypeGrammarParserTest.java index 295e0466a..6f1778097 100644 --- a/debezium-core/src/test/java/io/debezium/relational/ddl/DataTypeGrammarParserTest.java +++ b/debezium-core/src/test/java/io/debezium/relational/ddl/DataTypeGrammarParserTest.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/test/java/io/debezium/relational/ddl/DataTypeParserTest.java b/debezium-core/src/test/java/io/debezium/relational/ddl/DataTypeParserTest.java index 2a6f3206d..9521464c6 100644 --- a/debezium-core/src/test/java/io/debezium/relational/ddl/DataTypeParserTest.java +++ b/debezium-core/src/test/java/io/debezium/relational/ddl/DataTypeParserTest.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/test/java/io/debezium/relational/ddl/DdlParserSql2003Test.java b/debezium-core/src/test/java/io/debezium/relational/ddl/DdlParserSql2003Test.java index ec28bae5c..c86c3bf10 100644 --- a/debezium-core/src/test/java/io/debezium/relational/ddl/DdlParserSql2003Test.java +++ b/debezium-core/src/test/java/io/debezium/relational/ddl/DdlParserSql2003Test.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-core/src/test/java/io/debezium/text/PositionTest.java b/debezium-core/src/test/java/io/debezium/text/PositionTest.java index ee66c2bfe..c2af73e33 100644 --- a/debezium-core/src/test/java/io/debezium/text/PositionTest.java +++ b/debezium-core/src/test/java/io/debezium/text/PositionTest.java @@ -1,5 +1,5 @@ /* - * Copyright 2010 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ @@ -9,6 +9,9 @@ import static org.fest.assertions.Assertions.assertThat; +/** + * @author Randall Hauch + */ public class PositionTest { private int combinedIndex(int firstIndex, diff --git a/debezium-core/src/test/java/io/debezium/text/TokenStreamTest.java b/debezium-core/src/test/java/io/debezium/text/TokenStreamTest.java index e566ad619..1c829951b 100644 --- a/debezium-core/src/test/java/io/debezium/text/TokenStreamTest.java +++ b/debezium-core/src/test/java/io/debezium/text/TokenStreamTest.java @@ -1,5 +1,5 @@ /* - * Copyright 2010 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ @@ -15,6 +15,10 @@ import io.debezium.text.TokenStream.BasicTokenizer; import io.debezium.text.TokenStream.Tokenizer; +/** + * @author Randall Hauch + * @author Daniel Kelleher + */ public class TokenStreamTest { public static final int WORD = TokenStream.BasicTokenizer.WORD; public static final int SYMBOL = TokenStream.BasicTokenizer.SYMBOL; @@ -44,25 +48,25 @@ public void makeCaseInsensitive() { tokens.start(); } - @Test( expected = IllegalStateException.class ) + @Test(expected = IllegalStateException.class) public void shouldNotAllowConsumeBeforeStartIsCalled() { tokens = new TokenStream(content, TokenStream.basicTokenizer(false), false); tokens.consume("Select"); } - @Test( expected = IllegalStateException.class ) + @Test(expected = IllegalStateException.class) public void shouldNotAllowHasNextBeforeStartIsCalled() { tokens = new TokenStream(content, TokenStream.basicTokenizer(false), false); tokens.hasNext(); } - @Test( expected = IllegalStateException.class ) + @Test(expected = IllegalStateException.class) public void shouldNotAllowMatchesBeforeStartIsCalled() { tokens = new TokenStream(content, TokenStream.basicTokenizer(false), false); tokens.matches("Select"); } - @Test( expected = IllegalStateException.class ) + @Test(expected = IllegalStateException.class) public void shouldNotAllowCanConsumeBeforeStartIsCalled() { tokens = new TokenStream(content, TokenStream.basicTokenizer(false), false); tokens.canConsume("Select"); @@ -88,7 +92,7 @@ public void shouldConsumeInCaseSensitiveMannerWithExpectedValuesWhenMatchingExac assertThat(tokens.hasNext()).isFalse(); } - @Test( expected = ParsingException.class ) + @Test(expected = ParsingException.class) public void shouldFailToConsumeInCaseSensitiveMannerWithExpectedValuesWhenMatchingIncorrectCase() { makeCaseSensitive(); tokens.consume("Select"); @@ -108,7 +112,7 @@ public void shouldConsumeInCaseInsensitiveMannerWithExpectedValuesWhenMatchingNo assertThat(tokens.hasNext()).isFalse(); } - @Test( expected = ParsingException.class ) + @Test(expected = ParsingException.class) public void shouldFailToConsumeInCaseInsensitiveMannerWithExpectedValuesWhenMatchingStringIsInLowerCase() { makeCaseInsensitive(); tokens.consume("SELECT"); @@ -311,7 +315,7 @@ public void shouldConsumeMultipleTokensIfTheyMatch() { assertThat(tokens.hasNext()).isFalse(); } - @Test( expected = ParsingException.class ) + @Test(expected = ParsingException.class) public void shouldFailToConsumeMultipleTokensIfTheyDoNotMatch() { makeCaseInsensitive(); tokens.consume("SELECT", "ALL", "COLUMNS", "FROM", "TABLE"); @@ -327,8 +331,8 @@ public void shouldReturnTrueFromCanConsumeMultipleTokensIfTheyAllMatch() { @Test public void shouldReturnTrueFromCanConsumeArrayOfTokensIfTheyAllMatch() { makeCaseInsensitive(); - assertThat(tokens.matches(new String[] {"SELECT", "ALL", "COLUMNS", "FROM", "THIS", "TABLE"})).isTrue(); - assertThat(tokens.canConsume(new String[] {"SELECT", "ALL", "COLUMNS", "FROM", "THIS", "TABLE"})).isTrue(); + assertThat(tokens.matches(new String[] { "SELECT", "ALL", "COLUMNS", "FROM", "THIS", "TABLE" })).isTrue(); + assertThat(tokens.canConsume(new String[] { "SELECT", "ALL", "COLUMNS", "FROM", "THIS", "TABLE" })).isTrue(); assertThat(tokens.hasNext()).isFalse(); } @@ -417,7 +421,7 @@ public void shouldCanConsumeSingleAfterTokensCompleteFromCanConsumeStringList() public void shouldCanConsumeStringAfterTokensCompleteFromCanConsumeStringArray() { makeCaseInsensitive(); // consume ALL the tokens using canConsume() - tokens.canConsume(new String[] {"SELECT", "ALL", "COLUMNS", "FROM", "THIS", "TABLE"}); + tokens.canConsume(new String[] { "SELECT", "ALL", "COLUMNS", "FROM", "THIS", "TABLE" }); // try to canConsume() single word assertThat(tokens.canConsume("SELECT")).isFalse(); assertThat(tokens.canConsume(TokenStream.ANY_VALUE)).isFalse(); @@ -428,7 +432,7 @@ public void shouldCanConsumeStringAfterTokensCompleteFromCanConsumeStringArray() public void shouldCanConsumeStringAfterTokensCompleteFromCanConsumeStringIterator() { makeCaseInsensitive(); // consume ALL the tokens using canConsume() - tokens.canConsume(Arrays.asList(new String[] {"SELECT", "ALL", "COLUMNS", "FROM", "THIS", "TABLE"})); + tokens.canConsume(Arrays.asList(new String[] { "SELECT", "ALL", "COLUMNS", "FROM", "THIS", "TABLE" })); // try to canConsume() single word assertThat(tokens.canConsume("SELECT")).isFalse(); assertThat(tokens.canConsume(TokenStream.ANY_VALUE)).isFalse(); diff --git a/debezium-core/src/test/java/io/debezium/text/XmlCharactersTest.java b/debezium-core/src/test/java/io/debezium/text/XmlCharactersTest.java index 6816d812f..e2c83f370 100644 --- a/debezium-core/src/test/java/io/debezium/text/XmlCharactersTest.java +++ b/debezium-core/src/test/java/io/debezium/text/XmlCharactersTest.java @@ -1,5 +1,5 @@ /* - * Copyright 2010 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ @@ -9,6 +9,9 @@ import static org.fest.assertions.Assertions.assertThat; +/** + * @author Randall Hauch + */ public class XmlCharactersTest { @Test diff --git a/debezium-core/src/test/java/io/debezium/util/HashCodeTest.java b/debezium-core/src/test/java/io/debezium/util/HashCodeTest.java index 015b1aad7..bcf306a78 100644 --- a/debezium-core/src/test/java/io/debezium/util/HashCodeTest.java +++ b/debezium-core/src/test/java/io/debezium/util/HashCodeTest.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ @@ -11,6 +11,9 @@ import org.junit.Test; +/** + * @author Randall Hauch + */ public class HashCodeTest { @Test diff --git a/debezium-core/src/test/java/io/debezium/util/StringsTest.java b/debezium-core/src/test/java/io/debezium/util/StringsTest.java index e47c22a51..630db6b55 100644 --- a/debezium-core/src/test/java/io/debezium/util/StringsTest.java +++ b/debezium-core/src/test/java/io/debezium/util/StringsTest.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ @@ -14,6 +14,10 @@ import org.junit.Test; +/** + * @author Randall Hauch + * @author Horia Chiorean + */ public class StringsTest { public void compareSeparatedLines( Object... lines ) { diff --git a/debezium-ingest-jdbc/src/test/java/io/debezium/injest/jdbc/util/TestDatabase.java b/debezium-ingest-jdbc/src/test/java/io/debezium/injest/jdbc/util/TestDatabase.java index 90302d51c..95f2f86bc 100644 --- a/debezium-ingest-jdbc/src/test/java/io/debezium/injest/jdbc/util/TestDatabase.java +++ b/debezium-ingest-jdbc/src/test/java/io/debezium/injest/jdbc/util/TestDatabase.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-ingest-mysql/src/main/java/io/debezium/mysql/MySqlConfiguration.java b/debezium-ingest-mysql/src/main/java/io/debezium/mysql/MySqlConfiguration.java index 76d560fac..4427cf743 100644 --- a/debezium-ingest-mysql/src/main/java/io/debezium/mysql/MySqlConfiguration.java +++ b/debezium-ingest-mysql/src/main/java/io/debezium/mysql/MySqlConfiguration.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-ingest-mysql/src/main/java/io/debezium/mysql/MySqlDdlParser.java b/debezium-ingest-mysql/src/main/java/io/debezium/mysql/MySqlDdlParser.java index 87242135c..71ab2a67a 100644 --- a/debezium-ingest-mysql/src/main/java/io/debezium/mysql/MySqlDdlParser.java +++ b/debezium-ingest-mysql/src/main/java/io/debezium/mysql/MySqlDdlParser.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/Module.java b/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/Module.java index 1568c3f48..80e47372b 100644 --- a/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/Module.java +++ b/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/Module.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/MySqlChangeDetector.java b/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/MySqlChangeDetector.java index 5d62f3ba0..7a354b5b9 100644 --- a/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/MySqlChangeDetector.java +++ b/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/MySqlChangeDetector.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/MySqlConnector.java b/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/MySqlConnector.java index 847087b03..b5211723a 100644 --- a/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/MySqlConnector.java +++ b/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/MySqlConnector.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/SourceInfo.java b/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/SourceInfo.java index bc4b1982c..1c3cc510a 100644 --- a/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/SourceInfo.java +++ b/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/SourceInfo.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/TableConverters.java b/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/TableConverters.java index 77f120942..4e68e294c 100644 --- a/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/TableConverters.java +++ b/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/TableConverters.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/TopicSelector.java b/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/TopicSelector.java index b6d25ebf0..e8f5c3f90 100644 --- a/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/TopicSelector.java +++ b/debezium-ingest-mysql/src/main/java/io/debezium/mysql/ingest/TopicSelector.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-ingest-mysql/src/test/java/io/debezium/mysql/ConnectionIT.java b/debezium-ingest-mysql/src/test/java/io/debezium/mysql/ConnectionIT.java index 3fafb1d10..72a72904b 100644 --- a/debezium-ingest-mysql/src/test/java/io/debezium/mysql/ConnectionIT.java +++ b/debezium-ingest-mysql/src/test/java/io/debezium/mysql/ConnectionIT.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-ingest-mysql/src/test/java/io/debezium/mysql/MySQLConnection.java b/debezium-ingest-mysql/src/test/java/io/debezium/mysql/MySQLConnection.java index 4b373c792..b8cadebdc 100644 --- a/debezium-ingest-mysql/src/test/java/io/debezium/mysql/MySQLConnection.java +++ b/debezium-ingest-mysql/src/test/java/io/debezium/mysql/MySQLConnection.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-ingest-mysql/src/test/java/io/debezium/mysql/MySqlDdlParserTest.java b/debezium-ingest-mysql/src/test/java/io/debezium/mysql/MySqlDdlParserTest.java index 5a4c733e3..1b036e9de 100644 --- a/debezium-ingest-mysql/src/test/java/io/debezium/mysql/MySqlDdlParserTest.java +++ b/debezium-ingest-mysql/src/test/java/io/debezium/mysql/MySqlDdlParserTest.java @@ -1,5 +1,5 @@ /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-ingest-mysql/src/test/java/io/debezium/mysql/ingest/MetadataIT.java b/debezium-ingest-mysql/src/test/java/io/debezium/mysql/ingest/MetadataIT.java index 5387cc45e..c4541f5b0 100644 --- a/debezium-ingest-mysql/src/test/java/io/debezium/mysql/ingest/MetadataIT.java +++ b/debezium-ingest-mysql/src/test/java/io/debezium/mysql/ingest/MetadataIT.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-ingest-mysql/src/test/java/io/debezium/mysql/ingest/ReadBinLogIT.java b/debezium-ingest-mysql/src/test/java/io/debezium/mysql/ingest/ReadBinLogIT.java index 4018b04bd..024ec8e07 100644 --- a/debezium-ingest-mysql/src/test/java/io/debezium/mysql/ingest/ReadBinLogIT.java +++ b/debezium-ingest-mysql/src/test/java/io/debezium/mysql/ingest/ReadBinLogIT.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-ingest-postgres/src/main/java/io/debezium/ingest/postgres/PostgresConnection.java b/debezium-ingest-postgres/src/main/java/io/debezium/ingest/postgres/PostgresConnection.java index ec183d9bc..577bd6e86 100644 --- a/debezium-ingest-postgres/src/main/java/io/debezium/ingest/postgres/PostgresConnection.java +++ b/debezium-ingest-postgres/src/main/java/io/debezium/ingest/postgres/PostgresConnection.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/debezium-ingest-postgres/src/test/java/io/debezium/ingest/postgresql/ConnectionIT.java b/debezium-ingest-postgres/src/test/java/io/debezium/ingest/postgresql/ConnectionIT.java index b39d8565c..4cd80a814 100644 --- a/debezium-ingest-postgres/src/test/java/io/debezium/ingest/postgresql/ConnectionIT.java +++ b/debezium-ingest-postgres/src/test/java/io/debezium/ingest/postgresql/ConnectionIT.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/support/checkstyle/src/main/java/io/debezium/checkstyle/ExcludeTestPackages.java b/support/checkstyle/src/main/java/io/debezium/checkstyle/ExcludeTestPackages.java index d6a5aae68..5145d6f69 100644 --- a/support/checkstyle/src/main/java/io/debezium/checkstyle/ExcludeTestPackages.java +++ b/support/checkstyle/src/main/java/io/debezium/checkstyle/ExcludeTestPackages.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/support/checkstyle/src/main/java/io/debezium/checkstyle/Header.java b/support/checkstyle/src/main/java/io/debezium/checkstyle/Header.java index c1ae46aa9..f7a1c1612 100644 --- a/support/checkstyle/src/main/java/io/debezium/checkstyle/Header.java +++ b/support/checkstyle/src/main/java/io/debezium/checkstyle/Header.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ @@ -13,19 +13,15 @@ import java.util.HashSet; import java.util.List; import java.util.Set; -import java.util.function.Predicate; import java.util.regex.Pattern; public class Header extends com.puppycrawl.tools.checkstyle.checks.header.HeaderCheck { - private static final String YEAR_MATCHING_PATTERN = "${YYYY}"; - private Set excludedFileSet; private String excludedFilesRegex; private Pattern excludedFilesPattern; private final String workingDirPath = new File(".").getAbsoluteFile().getParentFile().getAbsolutePath(); private final int workingDirPathLength = workingDirPath.length(); - private Predicate yearLineMatcher; public Header() { } @@ -63,11 +59,6 @@ public void setHeaderFile( String aFileName ) { if (l == null) { break; } - if (l.contains(YEAR_MATCHING_PATTERN)) { - String prefix = l.substring(0, l.indexOf(YEAR_MATCHING_PATTERN)); - String suffix = l.substring(l.indexOf(YEAR_MATCHING_PATTERN)+YEAR_MATCHING_PATTERN.length()); - yearLineMatcher = (line)->line.startsWith(prefix) && line.endsWith(suffix); - } sb.append(l).append("\\n"); } super.setHeader(sb.toString()); @@ -100,19 +91,4 @@ protected void processFiltered( File aFile, if (isExcluded(aFile)) return; super.processFiltered(aFile, aLines); } - - /** - * Checks if a code line matches the required header line. - * @param lineNumber the line number to check against the header - * @param line the line contents - * @return true if and only if the line matches the required header line - */ - @Override - protected boolean isMatch(int lineNumber, String line) { - if ( super.isMatch(lineNumber, line)) return true; - // Otherwise it does not match, so see if the line contain our "${year}" string - if ( yearLineMatcher != null && yearLineMatcher.test(line) ) return true; - return false; - } - } \ No newline at end of file diff --git a/support/checkstyle/src/main/java/io/debezium/checkstyle/IllegalImport.java b/support/checkstyle/src/main/java/io/debezium/checkstyle/IllegalImport.java index 990bc2d7e..6afe3d73c 100644 --- a/support/checkstyle/src/main/java/io/debezium/checkstyle/IllegalImport.java +++ b/support/checkstyle/src/main/java/io/debezium/checkstyle/IllegalImport.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/support/checkstyle/src/main/java/io/debezium/checkstyle/JavaDocUtil.java b/support/checkstyle/src/main/java/io/debezium/checkstyle/JavaDocUtil.java index 24ea38611..cf59d3e58 100644 --- a/support/checkstyle/src/main/java/io/debezium/checkstyle/JavaDocUtil.java +++ b/support/checkstyle/src/main/java/io/debezium/checkstyle/JavaDocUtil.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/support/checkstyle/src/main/java/io/debezium/checkstyle/UnusedImports.java b/support/checkstyle/src/main/java/io/debezium/checkstyle/UnusedImports.java index 816b609fb..fc30a5b46 100644 --- a/support/checkstyle/src/main/java/io/debezium/checkstyle/UnusedImports.java +++ b/support/checkstyle/src/main/java/io/debezium/checkstyle/UnusedImports.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/support/checkstyle/src/main/resources/debezium.header b/support/checkstyle/src/main/resources/debezium.header index db8ced55b..9421e0aa4 100644 --- a/support/checkstyle/src/main/resources/debezium.header +++ b/support/checkstyle/src/main/resources/debezium.header @@ -1,5 +1,5 @@ /* - * Copyright ${YYYY} Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ diff --git a/support/ide-configs/eclipse/debezium-templates.xml b/support/ide-configs/eclipse/debezium-templates.xml index e80a9c67a..c50f7457e 100644 --- a/support/ide-configs/eclipse/debezium-templates.xml +++ b/support/ide-configs/eclipse/debezium-templates.xml @@ -7,7 +7,7 @@ id="org.eclipse.jdt.ui.text.codetemplates.filecomment" name="filecomment"> /* - * Copyright 2016 Debezium Authors. + * Copyright Debezium Authors. * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */