code: def create_and_load_tpch_schema(
      sql: sql_connection, only_create_tables: bool = False
  ):
      cnx = mysql.connector.connect(
          host=sql.hostname,
          port=sql.port,
          user=sql.username,
          password=sql.password,
          database=sql.schema,
          allow_local_infile=True,
      )
      cursor = cnx.cursor()
  
      conda_prefix = os.getenv("CONDA_PREFIX", "")
      tabs_dir = (
          conda_prefix
          + "/"
          + "blazingsql-testing-files/data/tpch-with-nulls/"
      )
  
      for (
          table,
          table_description,
      ) in mysql_tpch_table_descriptions.items():
          ok = create_mysql_table(table_description, cursor)
          if ok and not only_create_tables:
              table_files = "%s/%s_*.psv" % (tabs_dir, table)
              mysql_load_data_in_file(table, table_files, cursor, cnx)
          else:
              print(
                  "MySQL table %s already exists, will not load any data!"
                  % table
              )
  
      cursor.close()
      cnx.close()
  
file_path: blazingsql/tests/BlazingSQLTest/DataBase/mysqlSchema.py
imports: import os
  import glob
  from .createSchema import get_sql_connection, get_column_names, sql_connection
  from blazingsql import DataType
  import mysql.connector
  from mysql.connector import errorcode
label_desc: Use image node_id 3 for calling a global function with example usage: create_and_load_tpch_schema(sql, only_create_tables) without return types