From ca044108ba7c8a97214a5719157b0db590b1d678 Mon Sep 17 00:00:00 2001 From: Tyler Hobbs Date: Thu, 6 Mar 2014 16:22:08 -0600 Subject: [PATCH] Use prepared statements for benchmarks --- benchmarks/base.py | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/benchmarks/base.py b/benchmarks/base.py index 90f41703..f00df6b0 100644 --- a/benchmarks/base.py +++ b/benchmarks/base.py @@ -15,7 +15,6 @@ sys.path.append(os.path.join(dirname, '..')) from cassandra.cluster import Cluster from cassandra.io.asyncorereactor import AsyncoreConnection from cassandra.policies import HostDistance -from cassandra.query import SimpleStatement log = logging.getLogger() handler = logging.StreamHandler() @@ -86,11 +85,10 @@ def benchmark(thread_class): log.debug("Sleeping for two seconds...") time.sleep(2.0) - query = SimpleStatement(""" - INSERT INTO {table} (thekey, col1, col2) - VALUES (%(key)s, %(a)s, %(b)s) + query = session.prepare(""" + INSERT INTO {table} (thekey, col1, col2) VALUES (?, ?, ?)) """.format(table=TABLE)) - values = {'key': 'key', 'a': 'a', 'b': 'b'} + values = ('key', 'a', 'b') per_thread = options.num_ops / options.threads threads = []