| Line 401: |
Line 401: |
| | == Database Access == | | == Database Access == |
| | === MySQLdb === | | === MySQLdb === |
| | + | '''Table creation''' |
| | <source lang="python"> | | <source lang="python"> |
| | #!/usr/bin/python | | #!/usr/bin/python |
| Line 424: |
Line 425: |
| | | | |
| | cursor.execute(sql) | | cursor.execute(sql) |
| | + | </source> |
| | + | '''INSERT operation''' |
| | + | <source lang="python"> |
| | + | #!/usr/bin/python |
| | + | |
| | + | import MySQLdb |
| | + | |
| | + | # Open database connection |
| | + | db = MySQLdb.connect("DB_HOST","DB_USER","DB_PASSWORD","DB_NAME" ) |
| | + | |
| | + | # prepare a cursor object using cursor() method |
| | + | cursor = db.cursor() |
| | | | |
| | # Prepare SQL query to INSERT a record into the database. | | # Prepare SQL query to INSERT a record into the database. |
| Line 442: |
Line 455: |
| | db.close() | | db.close() |
| | </source> | | </source> |
| | + | |
| | + | '''Read example''' |
| | + | Once the query is made you can: |
| | + | *fetchone() |
| | + | *fetchall() |
| | + | *rowcount |
| | + | <source lang="python"> |
| | + | #!/usr/bin/python |
| | + | |
| | + | import MySQLdb |
| | + | |
| | + | # Open database connection |
| | + | db = MySQLdb.connect("localhost","testuser","test123","TESTDB" ) |
| | + | |
| | + | # prepare a cursor object using cursor() method |
| | + | cursor = db.cursor() |
| | + | |
| | + | # Prepare SQL query to INSERT a record into the database. |
| | + | sql = "SELECT * FROM EMPLOYEE \ |
| | + | WHERE INCOME > '%d'" % (1000) |
| | + | try: |
| | + | # Execute the SQL command |
| | + | cursor.execute(sql) |
| | + | # Fetch all the rows in a list of lists. |
| | + | results = cursor.fetchall() |
| | + | print "Found ', cursor.rowcount, ' results: ' |
| | + | for row in results: |
| | + | fname = row[0] |
| | + | lname = row[1] |
| | + | age = row[2] |
| | + | sex = row[3] |
| | + | income = row[4] |
| | + | # Now print fetched result |
| | + | print "fname=%s,lname=%s,age=%d,sex=%s,income=%d" % \ |
| | + | (fname, lname, age, sex, income ) |
| | + | except: |
| | + | print "Error: unable to fecth data" |
| | + | |
| | + | # disconnect from server |
| | + | db.close() |
| | + | </python> |
| | + | |
| | == ssh tunneling == | | == ssh tunneling == |
| | <source lang="python"> | | <source lang="python"> |