JupySQL

%load_ext sql
%config SqlMagic.autopandas=True

import pymysql
import pandas as pd

%sql?

%sql mysql+pymysql://jupyter:H4!b5at22@mariadb/sakila --alias mariadb
#%sql mariadb
%sql --connections

%sqlcmd tables

%%sql
SELECT * FROM actor

%sql --close mariadb

conn = pymysql.connect(
    host='mariadb',
    port=3306,
    user='jupyter',
    password='H4!b5at22',
    charset='utf8mb4',
    cursorclass=pymysql.cursors.DictCursor
)

# Cursor query 
cur = conn.cursor()
cur.execute("select title, description, release_year from sakila.film limit 20") 
output = cur.fetchall() 

for i in output: 
    print(i) 

# To close the connection 
conn.close() 

# Module Import
import mariadb
import sys

# Print List of Customers
def print_customers(cur):
     """Retrieves the list of actors from the database and prints to stdout"""

     # Initialize Variables
     customers = []

     # Retrieve customers
     cur.execute("SELECT first_name, last_name, email FROM sakila.customer LIMIT 20")

     # Prepare customers
     for (first_name, last_name, email) in cur:
        customers.append(f"{first_name} {last_name}: <{email}>")

     # List customers
     print("\n".join(customers))

# Instantiate Connection
try:
     conn = mariadb.connect(
        host="mariadb",
        port=3306,
        user="jupyter",
        password="H4!b5at22")

     # Instantiate Cursor
     cur = conn.cursor()

     print_customers(cur)

     # Close Connection
     conn.close()

except mariadb.Error as e:
      print(f"Error connecting to the database: {e}")
      sys.exit(1)