Skip to content

Commit

Permalink
Fix with groupId
Browse files Browse the repository at this point in the history
  • Loading branch information
Kirill380 committed Sep 6, 2016
1 parent 9591b56 commit d6dccf2
Show file tree
Hide file tree
Showing 28 changed files with 69 additions and 69 deletions.
5 changes: 3 additions & 2 deletions server/upgrade/data-migration-0.9.0-0.10.0/pom.xml
Expand Up @@ -4,7 +4,8 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

<modelVersion>4.0.0</modelVersion>
<groupId>org.kaaproject</groupId>

<groupId>org.kaaproject.kaa.server</groupId>
<artifactId>data-migration</artifactId>
<packaging>jar</packaging>

Expand Down Expand Up @@ -77,7 +78,7 @@
<executions>
<execution>
<configuration>
<mainClass>org.kaaproject.datamigration.MigrateData</mainClass>
<mainClass>org.kaaproject.kaa.server.datamigration.MigrateData</mainClass>
</configuration>
<goals>
<goal>one-jar</goal>
Expand Down
Expand Up @@ -14,21 +14,21 @@
* limitations under the License.
*/

package org.kaaproject.datamigration;
package org.kaaproject.kaa.server.datamigration;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.kaaproject.datamigration.model.Schema;
import org.kaaproject.datamigration.utils.BaseSchemaIdCounter;
import org.kaaproject.datamigration.utils.datadefinition.DataDefinition;
import org.kaaproject.kaa.server.datamigration.model.Schema;
import org.kaaproject.kaa.server.datamigration.utils.BaseSchemaIdCounter;
import org.kaaproject.kaa.server.datamigration.utils.datadefinition.DataDefinition;
import org.kaaproject.kaa.server.datamigration.utils.datadefinition.Constraint;
import org.kaaproject.kaa.server.datamigration.utils.datadefinition.ReferenceOptions;

import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;

import static java.util.stream.Collectors.joining;
import static org.kaaproject.datamigration.utils.datadefinition.Constraint.constraint;
import static org.kaaproject.datamigration.utils.datadefinition.ReferenceOptions.CASCADE;

public abstract class AbstractCTLMigration {
protected Connection connection;
Expand Down Expand Up @@ -74,11 +74,11 @@ protected List<Schema> transform() throws SQLException {

public void afterTransform() throws SQLException {
dd.alterTable(getPrefixTableName() + "_schems")
.add(constraint("FK_" + getPrefixTableName() + "_base_schems_id")
.add(Constraint.constraint("FK_" + getPrefixTableName() + "_base_schems_id")
.foreignKey("id")
.references("base_schems", "id")
.onDelete(CASCADE)
.onUpdate(CASCADE)
.onDelete(ReferenceOptions.CASCADE)
.onUpdate(ReferenceOptions.CASCADE)
)
.execute();
}
Expand Down
Expand Up @@ -14,12 +14,12 @@
* limitations under the License.
*/

package org.kaaproject.datamigration;
package org.kaaproject.kaa.server.datamigration;

import org.apache.commons.dbutils.QueryRunner;
import org.kaaproject.datamigration.model.Ctl;
import org.kaaproject.datamigration.model.Schema;
import org.kaaproject.datamigration.utils.datadefinition.DataDefinition;
import org.kaaproject.kaa.server.datamigration.model.Ctl;
import org.kaaproject.kaa.server.datamigration.model.Schema;
import org.kaaproject.kaa.server.datamigration.utils.datadefinition.DataDefinition;

import java.sql.Connection;
import java.sql.SQLException;
Expand Down
Expand Up @@ -14,16 +14,16 @@
* limitations under the License.
*/

package org.kaaproject.datamigration;
package org.kaaproject.kaa.server.datamigration;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.commons.dbutils.handlers.ScalarHandler;
import org.kaaproject.datamigration.model.Ctl;
import org.kaaproject.datamigration.model.CtlMetaInfo;
import org.kaaproject.datamigration.model.FlatCtl;
import org.kaaproject.datamigration.model.Schema;
import org.kaaproject.datamigration.utils.datadefinition.DataDefinition;
import org.kaaproject.kaa.server.datamigration.model.Ctl;
import org.kaaproject.kaa.server.datamigration.model.CtlMetaInfo;
import org.kaaproject.kaa.server.datamigration.model.FlatCtl;
import org.kaaproject.kaa.server.datamigration.model.Schema;
import org.kaaproject.kaa.server.datamigration.utils.datadefinition.DataDefinition;
import org.kaaproject.kaa.server.common.core.algorithms.generation.ConfigurationGenerationException;
import org.kaaproject.kaa.server.common.core.algorithms.generation.DefaultRecordGenerationAlgorithm;
import org.kaaproject.kaa.server.common.core.algorithms.generation.DefaultRecordGenerationAlgorithmImpl;
Expand Down
Expand Up @@ -14,13 +14,13 @@
* limitations under the License.
*/

package org.kaaproject.datamigration;
package org.kaaproject.kaa.server.datamigration;

import java.sql.Connection;
import java.sql.SQLException;

import static org.kaaproject.datamigration.utils.datadefinition.Constraint.constraint;
import static org.kaaproject.datamigration.utils.datadefinition.ReferenceOptions.CASCADE;
import static org.kaaproject.kaa.server.datamigration.utils.datadefinition.Constraint.constraint;
import static org.kaaproject.kaa.server.datamigration.utils.datadefinition.ReferenceOptions.CASCADE;

public class CTLConfigurationMigration extends AbstractCTLMigration {

Expand Down
Expand Up @@ -14,26 +14,25 @@
* limitations under the License.
*/

package org.kaaproject.datamigration;
package org.kaaproject.kaa.server.datamigration;

import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.kaaproject.datamigration.model.EventClass;
import org.kaaproject.datamigration.model.EventSchemaVersion;
import org.kaaproject.datamigration.model.Schema;
import org.kaaproject.datamigration.utils.BaseSchemaIdCounter;
import org.kaaproject.kaa.server.datamigration.model.EventClass;
import org.kaaproject.kaa.server.datamigration.model.EventSchemaVersion;
import org.kaaproject.kaa.server.datamigration.model.Schema;
import org.kaaproject.kaa.server.datamigration.utils.BaseSchemaIdCounter;
import org.kaaproject.kaa.server.datamigration.utils.datadefinition.Constraint;
import org.kaaproject.kaa.server.datamigration.utils.datadefinition.ReferenceOptions;

import java.io.IOException;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import static org.kaaproject.datamigration.utils.datadefinition.Constraint.constraint;
import static org.kaaproject.datamigration.utils.datadefinition.ReferenceOptions.CASCADE;

public class CTLEventsMigration extends AbstractCTLMigration {
private static final String EVENT_SCHEMA_VERSION_TABLE_NAME = "event_schems_versions";
private static final String EVENT_CLASS_FAMILY_TABLE_NAME = "events_class_family";
Expand Down Expand Up @@ -62,18 +61,18 @@ public void beforeTransform() throws SQLException {
@Override
public void afterTransform() throws SQLException {
dd.alterTable(EVENT_CLASS_TABLE_NAME)
.add(constraint("FK_events_class_family_versions_id")
.add(Constraint.constraint("FK_events_class_family_versions_id")
.foreignKey("events_class_family_versions_id")
.references("events_class_family_versions", "id")
.onDelete(CASCADE)
.onUpdate(CASCADE))
.onDelete(ReferenceOptions.CASCADE)
.onUpdate(ReferenceOptions.CASCADE))
.execute();

dd.alterTable(APPLICATION_EVENT_MAP_TABLE_NAME)
.add(constraint("FK_events_class_id")
.add(Constraint.constraint("FK_events_class_id")
.foreignKey("events_class_id")
.references("events_class", "id")
.onDelete(CASCADE))
.onDelete(ReferenceOptions.CASCADE))
.execute();
}

Expand Down
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package org.kaaproject.datamigration;
package org.kaaproject.kaa.server.datamigration;

import java.sql.Connection;

Expand Down
@@ -1,4 +1,4 @@
package org.kaaproject.datamigration;
package org.kaaproject.kaa.server.datamigration;

import com.datastax.driver.core.BatchStatement;
import com.datastax.driver.core.Cluster;
Expand All @@ -12,8 +12,8 @@
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Filters;
import org.bson.Document;
import org.kaaproject.datamigration.model.Schema;
import org.kaaproject.datamigration.utils.Options;
import org.kaaproject.kaa.server.datamigration.model.Schema;
import org.kaaproject.kaa.server.datamigration.utils.Options;

import java.nio.ByteBuffer;
import java.sql.Connection;
Expand Down
@@ -1,4 +1,4 @@
package org.kaaproject.datamigration;
package org.kaaproject.kaa.server.datamigration;


import com.datastax.driver.core.Cluster;
Expand Down
Expand Up @@ -14,15 +14,15 @@
* limitations under the License.
*/

package org.kaaproject.datamigration;
package org.kaaproject.kaa.server.datamigration;

import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.kaaproject.datamigration.model.Ctl;
import org.kaaproject.datamigration.model.Schema;
import org.kaaproject.datamigration.utils.BaseSchemaIdCounter;
import org.kaaproject.datamigration.utils.DataSources;
import org.kaaproject.datamigration.utils.Options;
import org.kaaproject.kaa.server.datamigration.model.Ctl;
import org.kaaproject.kaa.server.datamigration.model.Schema;
import org.kaaproject.kaa.server.datamigration.utils.BaseSchemaIdCounter;
import org.kaaproject.kaa.server.datamigration.utils.DataSources;
import org.kaaproject.kaa.server.datamigration.utils.Options;
import org.kaaproject.kaa.server.common.core.algorithms.generation.ConfigurationGenerationException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
Expand Down
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package org.kaaproject.datamigration;
package org.kaaproject.kaa.server.datamigration;

public class MigrationException extends RuntimeException {

Expand Down
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package org.kaaproject.datamigration;
package org.kaaproject.kaa.server.datamigration;

import com.datastax.driver.core.BatchStatement;
import com.datastax.driver.core.Cluster;
Expand All @@ -32,8 +32,8 @@
import org.bson.Document;
import org.codehaus.jackson.JsonNode;
import org.codehaus.jackson.map.ObjectMapper;
import org.kaaproject.datamigration.model.Configuration;
import org.kaaproject.datamigration.utils.Options;
import org.kaaproject.kaa.server.datamigration.model.Configuration;
import org.kaaproject.kaa.server.datamigration.utils.Options;

import java.io.IOException;
import java.sql.Connection;
Expand All @@ -44,7 +44,7 @@
import static com.datastax.driver.core.querybuilder.QueryBuilder.select;
import static com.datastax.driver.core.querybuilder.QueryBuilder.set;
import static com.datastax.driver.core.querybuilder.QueryBuilder.update;
import static org.kaaproject.datamigration.utils.Utils.encodeUuids;
import static org.kaaproject.kaa.server.datamigration.utils.Utils.encodeUuids;

public class UpdateUuidsMigration {
private Connection connection;
Expand Down
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package org.kaaproject.datamigration.model;
package org.kaaproject.kaa.server.datamigration.model;

import java.io.Serializable;

Expand Down
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package org.kaaproject.datamigration.model;
package org.kaaproject.kaa.server.datamigration.model;

public class Ctl {
private final Long id;
Expand Down
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package org.kaaproject.datamigration.model;
package org.kaaproject.kaa.server.datamigration.model;

public class CtlMetaInfo {
private final Long id;
Expand Down
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package org.kaaproject.datamigration.model;
package org.kaaproject.kaa.server.datamigration.model;

public class EventClass {
private Long id;
Expand Down
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package org.kaaproject.datamigration.model;
package org.kaaproject.kaa.server.datamigration.model;

public class EventSchemaVersion {
private Long id;
Expand Down
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package org.kaaproject.datamigration.model;
package org.kaaproject.kaa.server.datamigration.model;

import org.kaaproject.kaa.server.common.core.algorithms.generation.ConfigurationGenerationException;
import org.kaaproject.kaa.server.common.core.algorithms.generation.DefaultRecordGenerationAlgorithm;
Expand Down
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package org.kaaproject.datamigration.model;
package org.kaaproject.kaa.server.datamigration.model;

public class Schema {

Expand Down
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package org.kaaproject.datamigration.utils;
package org.kaaproject.kaa.server.datamigration.utils;

public class BaseSchemaIdCounter {
private static BaseSchemaIdCounter instance;
Expand Down
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package org.kaaproject.datamigration.utils;
package org.kaaproject.kaa.server.datamigration.utils;

import org.apache.commons.dbcp.BasicDataSource;

Expand Down
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package org.kaaproject.datamigration.utils;
package org.kaaproject.kaa.server.datamigration.utils;


final public class Options {
Expand Down
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package org.kaaproject.datamigration.utils;
package org.kaaproject.kaa.server.datamigration.utils;

import org.codehaus.jackson.JsonNode;
import org.codehaus.jackson.node.ObjectNode;
Expand Down
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package org.kaaproject.datamigration.utils.datadefinition;
package org.kaaproject.kaa.server.datamigration.utils.datadefinition;

public class BuilderException extends RuntimeException {

Expand Down
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package org.kaaproject.datamigration.utils.datadefinition;
package org.kaaproject.kaa.server.datamigration.utils.datadefinition;

public class Constraint {
private String constraintName;
Expand Down
Expand Up @@ -14,7 +14,7 @@
* limitations under the License.
*/

package org.kaaproject.datamigration.utils.datadefinition;
package org.kaaproject.kaa.server.datamigration.utils.datadefinition;

enum ConstraintType {
FK, PK, UNIQUE, CHECK
Expand Down

0 comments on commit d6dccf2

Please sign in to comment.