Unittest mysql

import mysql.connector as sql
 
def copy_to_other_db():
    try:
        connection = sql.connect(host='127.0.0.1',
                                 database='employees',
                                 user ="yurapc",
                                 password='Mysqlpassword1!')
 
        cursor = connection.cursor()
        cursor.execute("SELECT * FROM titles")
        query = cursor.fetchall()
 
        connection_2 = sql.connect(host='127.0.0.1',
                                 database='employees_2',
                                 user ="yurapc",
                                 password='Mysqlpassword1!')
 
        cursor_2 = connection_2.cursor()
        cursor_2.executemany("INSERT IGNORE INTO titles (emp_no, title, from_date, to_date) VALUES (%s, %s, %s, %s);", query)
        connection_2.commit()
        cursor_2.execute("SELECT * FROM titles")
        query_2 = cursor_2.fetchall()
        for x in query_2:
            print(x)
        print("Record inserted successfully into titles table")
 
    except sql.Error as error:
        print("Failed to insert into MySQL table {}".format(error))
 
    finally:
        if connection.is_connected() and connection_2.is_connected():
            cursor.reset()
            cursor_2.reset()
            connection.close()
            connection_2.close()
            print("Connection is closed")
 
copy_to_other_db()