anchor.diff:      process_flag(trap_exit, true),
       random:seed(os:timestamp()),
       Nodes = get_value(nodes, Opts, [{"127.0.0.1", 9042}]),
  +    Username = bin(get_value(username, Opts)),
  +    Password = bin(get_value(password, Opts)),
       IsSSL = get_value(ssl, Opts, false),
       SslOpts = get_value(ssl_opts, Opts, []),
       Transport = if IsSSL -> ssl; true -> tcp end,
       Logger = gen_logger:new(get_value(logger, Opts, {console, debug})),
       {ok, startup, #state{nodes     = Nodes,
  +                         username  = Username,
  +                         password  = Password,
                            callers   = [],
                            requests  = dict:new(),
                            ssl       = IsSSL,
  
positive.code: shutdown(Reason, State) ->
      {stop, {shutdown, Reason}, State}.
  
  
negative.code: -define(LOG(Logger, Level, Format, Args),
          Logger:Level("[ecql~p] " ++ Format, [self() | Args])).
  
  -define(PASSWORD_AUTHENTICATOR, <<"org.apache.cassandra.auth.PasswordAuthenticator">>).
  
  -type cql_result() :: {TableSpec :: binary(),
                         Columns   :: [tuple()],
                         Rows      :: list()}.
  