anchor.diff:  
   prepare_load_test_table() ->
       start(),
  -    erlcass:execute(<<"DROP KEYSPACE ", (?KEYSPACE)/binary>>),
  -    {ok, []} = erlcass:execute(<<"CREATE KEYSPACE ", (?KEYSPACE)/binary, " WITH replication = {'class': 'NetworkTopologyStrategy', '", (?CLUSTER_NAME)/binary, "': 3  }">>),
  +
  +    erlcass:query(<<"DROP KEYSPACE ", (?KEYSPACE)/binary>>),
  +    {ok, []} = erlcass:query(<<"CREATE KEYSPACE ", (?KEYSPACE)/binary, " WITH replication = {'class': 'NetworkTopologyStrategy', '", (?CLUSTER_NAME)/binary, "': 3  }">>),
   
       Cols = datatypes_columns([ascii, bigint, blob, boolean, decimal, double, float, int, timestamp, uuid, varchar, varint, timeuuid, inet]),
       Sql = <<"CREATE TABLE ", (?KEYSPACE)/binary, ".test_table(",  Cols/binary, " PRIMARY KEY(col1));">>,
       io:format(<<"exec: ~p ~n">>,[Sql]),
  -    {ok, []} = erlcass:execute(Sql),
  +    {ok, []} = erlcass:query(Sql),
   
       InsertQuery = <<"INSERT INTO ", (?KEYSPACE)/binary, ".test_table(col1, col2, col3, col4, col5, col6, col7, col8, col9, col10, col11, col12, col13, col14) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)">>,
  +    ok = erlcass:add_prepare_statement(add_load_test_record, InsertQuery),
   
       AsciiValBin = <<"hello">>,
       BigIntPositive = 9223372036854775807,
  
positive.code: 
  -include("erlcass.hrl").
  
  -export([start/0, profile/3, profile/4, prepare_load_test_table/0]).
  
  -define(KEYSPACE, <<"load_test_erlcass">>).
  -define(QUERY, {<<"SELECT col1, col2, col3, col4, col5, col6, col7, col8, col9, col10, col11, col12, col13, col14 FROM test_table WHERE col1 =?">>, ?CASS_CONSISTENCY_ONE}).
  
negative.code:     {ok, Timeuuid} = erlcass_uuid:gen_time(),
      Inet = <<"127.0.0.1">>,
  
      {ok, []} = erlcass:execute(add_load_test_record, [
              AsciiValBin,
              BigIntPositive,
              Blob,
              BooleanTrue,
              DecimalPositive,
              DoublePositive,
              FloatPositive,
              IntPositive,
              Timestamp,
              Uuid,
              Varchar1,
              Varint1,
              Timeuuid,
              Inet
      ]).
  
  display_progress(Results) ->
      if
  