test_err.py

# type: ignore
import unittest

from singlestoredb.mysql import err


__all__ = ['TestRaiseException']


class TestRaiseException(unittest.TestCase):

    def test_raise_mysql_exception(self):
        data = b'\xff\x15\x04#28000Access denied'
        with self.assertRaises(err.OperationalError) as cm:
            err.raise_mysql_exception(data)
        self.assertEqual(cm.exception.args, (1045, 'Access denied', None))