## @@start:TO CHECK THE CONNECTION to DB
from utils.db import execute_sql_query
import asyncio
async def main():
x = await execute_sql_query("SELECT * FROM information_schema.schemata")
for item in x:
print("--------------------------------")
print("schema_name: ",item["schema_name"])
print("schema_owner: ",item["schema_owner"])
print("--------------------------------")
if __name__ == "__main__":
asyncio.run(main())