From 88ae26d8a280d4c8a96c64ca333c2aa387dd9fd7 Mon Sep 17 00:00:00 2001 From: abejaranoh Date: Wed, 10 Jun 2020 11:03:14 +0200 Subject: [PATCH 1/3] cluster parameters added values on cluster call contact_points = ['127.0.0.1'], load_balancing_policy = None, protocol_version = 66 --- example.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/example.py b/example.py index 86ac9eaa42..df875d28e1 100755 --- a/example.py +++ b/example.py @@ -15,7 +15,7 @@ KEYSPACE = "testkeyspace" def main(): - cluster = Cluster(['127.0.0.1']) + cluster = Cluster(contact_points = ['127.0.0.1'], load_balancing_policy = None, protocol_version = 66) session = cluster.connect() rows = session.execute("SELECT keyspace_name FROM system.schema_keyspaces") From 047210ae2a53d22799d198824495b41fda5aa055 Mon Sep 17 00:00:00 2001 From: abejaranoh Date: Wed, 10 Jun 2020 11:16:56 +0200 Subject: [PATCH 2/3] system_schema.keyspaces system_schema.keyspaces corrected --- example.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/example.py b/example.py index df875d28e1..40b2916d91 100755 --- a/example.py +++ b/example.py @@ -18,7 +18,7 @@ def main(): cluster = Cluster(contact_points = ['127.0.0.1'], load_balancing_policy = None, protocol_version = 66) session = cluster.connect() - rows = session.execute("SELECT keyspace_name FROM system.schema_keyspaces") + rows = session.execute("SELECT keyspace_name FROM system_schema.keyspaces") if KEYSPACE in [row[0] for row in rows]: log.info("dropping existing keyspace...") session.execute("DROP KEYSPACE " + KEYSPACE) From e8ce105a8e748310f8f62489cd01107a652cf067 Mon Sep 17 00:00:00 2001 From: abejaranoh Date: Wed, 10 Jun 2020 11:22:54 +0200 Subject: [PATCH 3/3] Update example.py --- example.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/example.py b/example.py index 40b2916d91..6d9dcc0f9a 100755 --- a/example.py +++ b/example.py @@ -15,7 +15,7 @@ KEYSPACE = "testkeyspace" def main(): - cluster = Cluster(contact_points = ['127.0.0.1'], load_balancing_policy = None, protocol_version = 66) + cluster = Cluster(contact_points = ['127.0.0.1'], load_balancing_policy = None, protocol_version = 4) session = cluster.connect() rows = session.execute("SELECT keyspace_name FROM system_schema.keyspaces")