diff --git a/example.py b/example.py
index 86ac9eaa42..6d9dcc0f9a 100755
--- a/example.py
+++ b/example.py
@@ -15,10 +15,10 @@
 KEYSPACE = "testkeyspace"
 
 def main():
-    cluster = Cluster(['127.0.0.1'])
+    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")
+    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)