Examples of CreateKeySpace

Examples of org.easycassandra.persistence.cassandra.FixKeySpaceUtil.CreateKeySpace

56
57
58
59
60
61
62
63
64
65
66
67
68
    }

    public void createKeySpace(KeySpaceQueryInformation information, Session session) {

        CreateKeySpace createKeySpace = FixKeySpaceUtil.INSTANCE
                .getCreate(information.getReplicaStrategy());
        try {
            session.execute(createKeySpace.createQuery(information));
        } catch (InvalidQueryException exception) {
            error(information, createKeySpace, exception);
        }
    }
View Full Code Here

Examples of org.easycassandra.persistence.cassandra.FixKeySpaceUtil.CreateKeySpace

41
42
43
44
45
46
47
48
49
50
51
52
    @Test
    public void networkdTest() {
        KeySpaceQueryInformation query = new KeySpaceQueryInformation();
        query.setReplicaStrategy(ReplicaStrategy.NETWORK_TOPOLOGY_STRATEGY);
        query.setKeySpace("javabahia");
        CreateKeySpace createKeySpace = FixKeySpaceUtil.INSTANCE
                .getCreate(query.getReplicaStrategy());
        Assert.assertEquals(
                createKeySpace.createQuery(query),
                NETWORK_TEST);

    }
View Full Code Here

Examples of org.easycassandra.persistence.cassandra.FixKeySpaceUtil.CreateKeySpace

61
62
63
64
65
66
67
68
69
70
71
72
        query.setKeySpace("javabahia");
        Map<String, Integer> map = new LinkedHashMap<>();
        query.setDataCenter(map);
        query.getDataCenter().put("DC1", 1);
        query.getDataCenter().put("DC2", THREE);
        CreateKeySpace createKeySpace = FixKeySpaceUtil.INSTANCE
                .getCreate(query.getReplicaStrategy());
        Assert.assertEquals(
                createKeySpace.createQuery(query),
                NETWORK_DC_TEST);

    }
View Full Code Here

Examples of org.easycassandra.persistence.cassandra.FixKeySpaceUtil.CreateKeySpace

77
78
79
80
81
82
83
84
85
86
87
88
    public void simpleTest() {
        KeySpaceQueryInformation query = new KeySpaceQueryInformation();
        query.setReplicaStrategy(ReplicaStrategy.SIMPLES_TRATEGY);
        query.setKeySpace("javabahia");
        query.setFactor(THREE);
        CreateKeySpace createKeySpace = FixKeySpaceUtil.INSTANCE
                .getCreate(query.getReplicaStrategy());
        Assert.assertEquals(
                createKeySpace.createQuery(query),
                SIMPLE_TEST);

    }
View Full Code Here

Examples of org.easycassandra.persistence.cassandra.FixKeySpaceUtil.CreateKeySpace

92
93
94
95
96
97
98
99
100
101
    @Test (expected = CreateKeySpaceException.class)
    public void customMandatoryTest() {
        KeySpaceQueryInformation query = new KeySpaceQueryInformation();
        query.setReplicaStrategy(ReplicaStrategy.CUSTOM_STRATEGY);
        query.setKeySpace("javabahia");
        CreateKeySpace createKeySpace = FixKeySpaceUtil.INSTANCE
                .getCreate(query.getReplicaStrategy());
        createKeySpace.createQuery(query);

    }
View Full Code Here

Examples of org.easycassandra.persistence.cassandra.FixKeySpaceUtil.CreateKeySpace

106
107
108
109
110
111
112
113
114
115
    public void customWithOutBeginTest() {
        KeySpaceQueryInformation query = new KeySpaceQueryInformation();
        query.setReplicaStrategy(ReplicaStrategy.CUSTOM_STRATEGY);
        query.setKeySpace("javabahia");
        query.setCustomQuery(CUSTOM_QUERY_ERRO_TEST);
        CreateKeySpace createKeySpace = FixKeySpaceUtil.INSTANCE
                .getCreate(query.getReplicaStrategy());
        createKeySpace.createQuery(query);

    }
View Full Code Here

Examples of org.easycassandra.persistence.cassandra.FixKeySpaceUtil.CreateKeySpace

121
122
123
124
125
126
127
128
129
130
131
    public void customTest() {
        KeySpaceQueryInformation query = new KeySpaceQueryInformation();
        query.setReplicaStrategy(ReplicaStrategy.CUSTOM_STRATEGY);
        query.setKeySpace("javabahia");
        query.setCustomQuery(CUSTOM_QUERY);
        CreateKeySpace createKeySpace = FixKeySpaceUtil.INSTANCE
                .getCreate(query.getReplicaStrategy());

        Assert.assertEquals(createKeySpace.createQuery(query), query.getCustomQuery());

    }
View Full Code Here

Examples of org.lealone.cassandra.command.ddl.CreateKeyspace

112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
        }
        return defs;
    }

    protected Prepared parseCreateKeyspace() {
        CreateKeyspace command = new CreateKeyspace(session);

        command.setIfNotExists(readIfNoExists());
        command.setKeyspaceName(readUniqueIdentifier());

        if (readIf("AUTHORIZATION")) {
            command.setAuthorization(readUniqueIdentifier());
        } else {
            command.setAuthorization(session.getUser().getName());
        }
        KSPropDefs defs = parseKSPropDefs();
        command.setKSPropDefs(defs);
        return command;
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.