# -*- coding: utf-8 -*-
from cassandra.cluster import Cluster
from settings import cluster_ip, cluster_port

cluster = Cluster([cluster_ip],port= cluster_port)
session = cluster.connect()
#session.execute("create KEYSPACE test_cassandra WITH replication = {'class':'SimpleStrategy', 'replication_factor': 2};")
session.execute("use test_cassandra")
#session.execute("create table users(id int, name text, primary key(id));")
session.execute("drop table if exists users");
session.execute("create table users(id int, name text,primary key(id));")
print 'recreate table success'