VARBYTE is decoded into utf-8 #261

import redshift_connector


DROP_DDL = "drop table if exists varbyte_repro"
CREATE_DDL = """create table varbyte_repro(
    my_var varbyte
);
"""
INSERT_DML = "insert into varbyte_repro(my_var) values (from_hex(SHA1('hello')))"
QUERY = "select * from varbyte_repro"

with redshift_connector.connect(
    host="replaced",
    database="replaced",
    user="replaced",
    password="replaced",
) as conn, conn.cursor() as cursor:
    conn.autocommit = True
    cursor.execute(DROP_DDL)
    cursor.execute(CREATE_DDL)
    cursor.execute(INSERT_DML)
    cursor.execute(QUERY)