Monday, 23 January 2023

Python - Insert into Maria DB

#import mysql.connector
# Module Imports
import mariadb
import sys

try:
    conn = mariadb.connect(
        user="root",
        password="root",
        host="127.0.0.1",
        port=3306,
        database="my_workspace"

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

# Get Cursor


cur = conn.cursor()
 

#insert information
try:
    cur.execute("INSERT INTO employee (Emp_No,Emp_Name,Emp_Add,Emp_Phone,Dept_No,Dept_Name,Salary) VALUES (?, ?, ?, ?, ?, ?, ?)", (9,"Maria","Mumbai",8908908900,3445,"DB",22222))
except mariadb.Error as e:
    print(f"Error: {e}")

conn.commit()     
conn.close()

 

 

 

SAMPLE TABLE CREATION SQL:

 

CREATE TABLE `employee` (
    `Emp_NO` INT(11) NOT NULL,
    `Emp_Name` TEXT NOT NULL,
    `Emp_Add` TEXT NOT NULL,
    `Emp_Phone` TEXT NOT NULL,
    `Dept_No` TEXT NOT NULL,
    `Dept_Name` TEXT NOT NULL,
    `Salary` TEXT NOT NULL,
    PRIMARY KEY (`Emp_NO`)
)

DBT - Models

Models are where your developers spend most of their time within a dbt environment. Models are primarily written as a select statement and ...