code: def create_and_load_tpch_schema(
      sql: sql_connection, only_create_tables: bool = False
  ):
      # allow_local_infile = True)
      cnx = psycopg2.connect(
          dbname=sql.schema,
          user=sql.username,
          host=sql.hostname,
          port=int(sql.port),
          password=sql.password,
      )
      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 postgresql_tpch_table_descriptions.items():
          cursor.execute(f"DROP TABLE IF EXISTS {table}")
          cnx.commit()
          ok = create_postgresql_table(table_description, cursor)
          cnx.commit()
          if ok and not only_create_tables:
              table_files = "%s/%s_*.psv" % (tabs_dir, table)
              postgresql_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/postgreSQLSchema.py
imports: import os
  import glob
  from .createSchema import get_sql_connection, get_column_names, sql_connection
  from blazingsql import DataType
  import psycopg2
label_desc: Use image node_id 4 for calling a global function with example usage: create_and_load_tpch_schema(sql, only_create_tables) without return types