execute Cassandra cqlsh in Java

UPDATE: 2018-9-12 一年了才知道push的第一行代码是用的Cassandra的官方java驱动。

package club.kaii;

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Session;
/**
 * author Genius Kaii
*
 */
public class CassandraConnecter {
    public Cluster cluster;
    public Session session;

    public void connect(String ip, int port, String username, String pwd) {
        cluster = Cluster.builder().addContactPoints(ip).withPort(port).withCredentials(username, pwd).build();
        session = cluster.connect();
    }
    
    public void createKeyspace(String keyspaceName, String strategy, int factor){
        String cql = "CREATE KEYSPACE IF NOT EXISTS" + keyspaceName + " WITH replication = {'class': '" + strategy + "', 'replication_factor': '" + factor + "'};";
        session.execute(cql);
    }

    public void closeConnection(){
        session.close();
    }
}