sqlalchemy/community

So, I have a bit of an interesting problem. For reasons I won't get into here, I want to store binary data in a database. When a client sends me a value, my program should check whether that value, encoded in binary data, is stored in the database.

Here is somewhat of an MCVE:

from http.server import BaseHTTPRequestHandler, HTTPServer
import json

from sqlalchemy import BINARY, Column, Date, ForeignKey, LargeBinary, create_engine, func, select
import sqlalchemy
from sqlalchemy.engine.base import Engine
from sqlalchemy.orm import declarative_base
from sqlalchemy import Column, String, Integer, DateTime
from sqlalchemy.orm import relationship, Session
from sqlalchemy import insert

Base = declarative_base()
engine = create_engine(
    "mysql+pymysql://user:password@localhost/api_database")


class Token(Base):
    __tablename__ = "Tokens"
    token = Column(BINARY(64), primary_key=True, nullable=False)


Base.metadata.create_all(engine)

with Session(bind=engine) as session:
    # add token
    session.add(Token(token="$2b$2t.e".encode("utf8")))
    session.commit()


class Server(BaseHTTPRequestHandler):

    def do_POST(self):
        input_length = int(self.headers.get("Content-Length"))
        input = self.rfile.read(input_length)
        input_json = json.loads(input)
        # check if passed token exists in table
        resultset = engine.execute(
            select(func.count(Token.token)).where(
                Token.token == input_json["token"].encode("utf8")))
        result_count = resultset.first()
        if (result_count[0] > 0):
            # found the token
            self.send_response(200)
            self.send_header("Content-Type", "application/json")
            self.end_headers()
            self.wfile.write(
                json.dumps({
                    "success": True
                }).encode("iso-8859-1"))
        else:
            # token not found
            self.send_response(400)
            self.send_header("Content-Type", "application/json")
            self.end_headers()
            self.wfile.write(
                json.dumps({
                    "success": False
                }).encode("iso-8859-1"))


if __name__ == "__main__":
    web_server = HTTPServer(("0.0.0.0", 8080), Server)
    print("Server started at {0}:{1}".format("0.0.0.0", 8080))
    try:
        web_server.serve_forever()
    except KeyboardInterrupt:
        pass
    web_server.server_close()
    print("Server stopped.")