a00ea9be88393565c2cdf2e8b8904c493354ba54,mindsdb/integrations/mysql/mysql.py,MySQL,_query,#MySQL#Any#,42

Before Change

    def _query(self, query):
        con = mysql.connector.connect(
            host=self.config["integrations"][self.name]["host"],
            port=self.config["integrations"][self.name]["port"],
            user=self.config["integrations"][self.name]["user"],
            password=self.config["integrations"][self.name]["password"]

After Change

    def _query(self, query):
        con = self._get_connnection()
        with closing(con) as con:
            cur = con.cursor(dictionary=True, buffered=True)
            cur.execute(query)
            res = True
            try:
                res = cur.fetchall()
            except Exception:
                pass
            con.commit()

        return res

    def _get_connect_string(self, table):
        user = f"{self.config["api"]["mysql"]["user"]}_{self.name}"

Instances