diff --git a/src/main/java/biz/nynja/account/StartupScriptsListener.java b/src/main/java/biz/nynja/account/StartupScriptsListener.java index fb650abfe51de4d10999384627dfd4be359ba7b8..08acd3a00f23296f1a2dea8daed47594d640f365 100644 --- a/src/main/java/biz/nynja/account/StartupScriptsListener.java +++ b/src/main/java/biz/nynja/account/StartupScriptsListener.java @@ -44,7 +44,7 @@ public class StartupScriptsListener { + ".accountbyauthenticationprovider AS SELECT * FROM account " + "WHERE authenticationprovider IS NOT NULL " + "PRIMARY KEY (authenticationprovider, accountid);"; - String scriptAccountViewByАccountName = "CREATE MATERIALIZED VIEW IF NOT EXISTS " + keyspace + String scriptAccountViewByAccountName = "CREATE MATERIALIZED VIEW IF NOT EXISTS " + keyspace + ".accountbyaccountname AS SELECT * FROM account " + "WHERE accountname IS NOT NULL " + "PRIMARY KEY (accountname, accountid);"; @@ -53,10 +53,10 @@ public class StartupScriptsListener { + "PRIMARY KEY (username, accountid);"; String scriptPendingAccountViewByAuthenticationProvider = "CREATE MATERIALIZED VIEW IF NOT EXISTS " + keyspace - + ".pendingaccountbyauthenticationprovider AS SELECT * FROM pending_account " + "WHERE authentication_provider IS NOT NULL " - + "PRIMARY KEY (authentication_provider, account_id);"; + + ".pendingaccountbyauthenticationprovider AS SELECT * FROM pendingaccount " + "WHERE authenticationprovider IS NOT NULL " + + "PRIMARY KEY (authenticationprovider, accountid);"; return Arrays.asList(scriptAccountViewByProfileId, scriptAccountViewByAuthProvider, - scriptAccountViewByАccountName, scriptAccountViewByUsername, scriptPendingAccountViewByAuthenticationProvider); + scriptAccountViewByAccountName, scriptAccountViewByUsername, scriptPendingAccountViewByAuthenticationProvider); } } \ No newline at end of file diff --git a/src/main/java/biz/nynja/account/models/AccountByCommunicationProvider.java b/src/main/java/biz/nynja/account/models/AccountByCommunicationProvider.java index a6354f5922258825336faa3a032998bba158a45f..f64d3a9c1aa55b9454a4a8e574ab47b7972254b1 100644 --- a/src/main/java/biz/nynja/account/models/AccountByCommunicationProvider.java +++ b/src/main/java/biz/nynja/account/models/AccountByCommunicationProvider.java @@ -7,22 +7,19 @@ import java.nio.ByteBuffer; import java.util.UUID; import org.springframework.data.cassandra.core.cql.PrimaryKeyType; -import org.springframework.data.cassandra.core.mapping.Column; import org.springframework.data.cassandra.core.mapping.PrimaryKeyColumn; import org.springframework.data.cassandra.core.mapping.Table; -@Table("account_by_communication_provider") +@Table public class AccountByCommunicationProvider { - @PrimaryKeyColumn(name = "communication_provider", ordinal = 0, type = PrimaryKeyType.PARTITIONED) + @PrimaryKeyColumn(ordinal = 0, type = PrimaryKeyType.PARTITIONED) private String communicationProvider; - @PrimaryKeyColumn(name = "communication_provider_type", ordinal = 1, type = PrimaryKeyType.PARTITIONED) + @PrimaryKeyColumn(ordinal = 1, type = PrimaryKeyType.PARTITIONED) private String communicationProviderType; - @PrimaryKeyColumn(name = "account_id", ordinal = 2, type = PrimaryKeyType.CLUSTERED) + @PrimaryKeyColumn(ordinal = 2, type = PrimaryKeyType.CLUSTERED) private UUID accountId; - @Column("account_name") private String accountName; - @Column("first_name") private String firstName; private ByteBuffer avatar; diff --git a/src/main/java/biz/nynja/account/models/PendingAccount.java b/src/main/java/biz/nynja/account/models/PendingAccount.java index 5f95c671517d0717ae7dea9ef1e632618fff25d9..11d77581bdc460314c7dd6d49f0e105f7dfb4baf 100644 --- a/src/main/java/biz/nynja/account/models/PendingAccount.java +++ b/src/main/java/biz/nynja/account/models/PendingAccount.java @@ -3,26 +3,20 @@ */ package biz.nynja.account.models; -import java.util.Date; import java.util.UUID; -import org.springframework.data.cassandra.core.mapping.Column; import org.springframework.data.cassandra.core.mapping.PrimaryKey; import org.springframework.data.cassandra.core.mapping.Table; import biz.nynja.account.grpc.CreatePendingAccountRequest; -@Table("pending_account") +@Table public class PendingAccount { - @PrimaryKey("account_id") + @PrimaryKey private UUID accountId; - @Column("profile_id") private UUID profileId; - @Column("authentication_provider") private String authenticationProvider; - @Column("authentication_provider_type") private String authenticationProviderType; - @Column("creation_timestamp") private Long creationTimestamp; public UUID getAccountId() { diff --git a/src/main/java/biz/nynja/account/models/PendingAccountByAuthenticationProvider.java b/src/main/java/biz/nynja/account/models/PendingAccountByAuthenticationProvider.java index 8c3dcdca5b4d8df5e9256ead344d88c0156cd10a..35c07e919e4d4f9a2925926efee711a47745262b 100644 --- a/src/main/java/biz/nynja/account/models/PendingAccountByAuthenticationProvider.java +++ b/src/main/java/biz/nynja/account/models/PendingAccountByAuthenticationProvider.java @@ -5,18 +5,11 @@ package biz.nynja.account.models; import java.util.UUID; -import org.springframework.data.cassandra.core.mapping.Column; - public class PendingAccountByAuthenticationProvider { - @Column("account_id") private UUID accountId; - @Column("profile_id") private UUID profileId; - @Column("authentication_provider") private String authenticationProvider; - @Column("authentication_provider_type") private String authenticationProviderType; - @Column("creation_timestamp") private Long creationTimestamp; public UUID getAccountId() { diff --git a/src/main/java/biz/nynja/account/models/ProfileByAuthenticationProvider.java b/src/main/java/biz/nynja/account/models/ProfileByAuthenticationProvider.java index fee3e5cf6e614db542c9cf7438757d3aaf311fd6..cbfd96b357421e9323f1c6ef06ee7f7d6de85c38 100644 --- a/src/main/java/biz/nynja/account/models/ProfileByAuthenticationProvider.java +++ b/src/main/java/biz/nynja/account/models/ProfileByAuthenticationProvider.java @@ -6,18 +6,16 @@ package biz.nynja.account.models; import java.util.UUID; import org.springframework.data.cassandra.core.cql.PrimaryKeyType; -import org.springframework.data.cassandra.core.mapping.Column; import org.springframework.data.cassandra.core.mapping.PrimaryKeyColumn; import org.springframework.data.cassandra.core.mapping.Table; -@Table("profile_by_authentication_provider") +@Table public class ProfileByAuthenticationProvider { - @PrimaryKeyColumn(name = "authentication_provider", ordinal = 0, type = PrimaryKeyType.PARTITIONED) + @PrimaryKeyColumn(ordinal = 0, type = PrimaryKeyType.PARTITIONED) private String authenticationProvider; - @PrimaryKeyColumn(name = "authentication_provider_type", ordinal = 1, type = PrimaryKeyType.PARTITIONED) + @PrimaryKeyColumn(ordinal = 1, type = PrimaryKeyType.PARTITIONED) private String authenticationProviderType; - @Column("profile_id") private UUID profileId; public String getAuthenticationProvider() {