-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathSample.py
49 lines (39 loc) · 1.72 KB
/
Sample.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
import psycopg2
def createTable():
connectObj = psycopg2.connect("dbname='database1' user='postgres' password='priyanka' host='127.0.0.1' port='5432'")
cursorObj = connectObj.cursor()
cursorObj.execute("CREATE TABLE IF NOT EXISTS store (item TEXT, quantity INTEGER, price REAL)")
connectObj.commit()
connectObj.close()
def insertData(item,quantity,price):
connectObj = psycopg2.connect("dbname='database1' user='postgres' password='priyanka' host='127.0.0.1' port='5432'")
cursorObj = connectObj.cursor()
cursorObj.execute("INSERT INTO store VALUES(%s,%s,%s)",(item,quantity,price))
connectObj.commit()
connectObj.close()
insertData("Coffee Cup",10,4.5)
def viewData():
connectObj = psycopg2.connect("dbname='database1' user='postgres' password='priyanka' host='127.0.0.1' port='5432'")
cursorObj = connectObj.cursor()
cursorObj.execute("SELECT * FROM store")
allRows = cursorObj.fetchall()
connectObj.close()
return allRows
def deleteData(item):
connectObj = psycopg2.connect("dbname='database1' user='postgres' password='priyanka' host='127.0.0.1' port='5432'")
cursorObj = connectObj.cursor()
cursorObj.execute("DELETE FROM store WHERE item=%s",(item,))
connectObj.commit()
connectObj.close()
def updateData(item,quantity,price):
connectObj = psycopg2.connect("dbname='database1' user='postgres' password='priyanka' host='127.0.0.1' port='5432'")
cursorObj = connectObj.cursor()
cursorObj.execute("UPDATE store SET quantity=%s, price=%s WHERE item=%s",(quantity,price,item))
connectObj.commit()
connectObj.close()
createTable()
insertData("Straberry",4,20.7)
print(viewData())
updateData("Apple",10,90)
print(viewData())
deleteData("Apple")