diff --git a/cqlengine/connection.py b/cqlengine/connection.py index 1b4f6b0a..988d5fd2 100644 --- a/cqlengine/connection.py +++ b/cqlengine/connection.py @@ -60,6 +60,9 @@ def setup( def execute(query, params=None, consistency_level=None): + if not session: + raise CQLEngineException("It is required to setup() cqlengine before executing queries") + if consistency_level is None: consistency_level = default_consistency_level @@ -75,6 +78,7 @@ def execute(query, params=None, consistency_level=None): query = SimpleStatement(query, consistency_level=consistency_level) + params = params or {} result = session.execute(query, params)