Tuesday, February 21, 2017

Simple CRUD operation on MYSQL using Python


To perform CRUD operation make sure you have installed MYSQLdb pacakge in your Python.
Like anyother programing language Python also need below step to perform CRUD on Database.
1-Import required API module for us as the data base is MYSQL we should import MYSQLdb in our Python file.
2- Acquiring connection with the database.
3- Performing SQL statments
4:- Closing the connection
import MySQLdb
# Open database connection
db = MySQLdb.connect("localhost","siddhu","siddhu","testsiddhu" )
# prepare a cursor object using cursor() method
cursor = db.cursor()
# execute SQL query 
cursor.execute("SELECT VERSION()")
# Fetch a single row 
data = cursor.fetchone()
print ("Database version : %s " % data)
# Drop table if it already exist 
cursor.execute("DROP TABLE IF EXISTS SIDDHU_TEST")
# Create table Example
sql = """CREATE TABLE SIDDHU_TEST (
FNAME CHAR(20) NOT NULL,
LNAME CHAR(20),
AGE INT, 
GENDER CHAR(1),
INCOME FLOAT )"""
cursor.execute(sql)
# Inserting in Table Example:- Prepare SQL query to INSERT a record into the database and accept the value dynamic. This is similar to prepare statement which we create.
sql = "INSERT INTO SIDDHU_TEST(FNAME, \
LNAME, AGE, GENDER, INCOME) \
VALUES ('%s', '%s', '%d', '%c', '%d' )" % \
('siddhu', 'dhumale', 24, 'M', 1000)
try:
# Execute command
cursor.execute(sql)
# Commit changes
db.commit()
except:
# Rollback if needed
db.rollback()
# disconnect from server
# Select Query Example :- Selecting data from the table.
sql = "SELECT * FROM SIDDHU_TEST \
WHERE AGE > '%d'" % (4)
try:
# Execute the SQL command
cursor.execute(sql)
# Fetch all the rows in a list of lists.
results = cursor.fetchall()
for row in results:
fname = row[0]
lname = row[1]
age = row[2]
gender = row[3]
income = row[4]
# Now print fetched result
print ("fname=%s,lname=%s,age=%d,gender=%s,income=%d" % (fname, lname, age, gender, income ))
print ("New fname=,lname=,age=,gender=,income=" % (fname, lname, age, gender, income ))
except:
print ("Value Fetch properly")


# Update Exmaple:- Update record 
sql = "UPDATE SIDDHU_TEST SET INCOME = 5000 WHERE GENDER = '%c'" % ('M')
try:
# Execute the SQL command
cursor.execute(sql)
# Commit your changes in the database
db.commit()
except:
# Rollback in case there is any error
db.rollback() 

# Delete Operation :- Delete Opearations
sql = "DELETE FROM SIDDHU_TEST WHERE INCOME = '%d'" % (5000)
try:
# Execute the SQL command
cursor.execute(sql)
# Commit your changes in the database
db.commit()
except:
# Rollback in case there is any error
db.rollback()


db.close()

No comments: