python通过MySQLdb访问mysql数据库,mysqldbmysql,需要安装MySQLdb,


需要安装MySQLdb,windows下安装需要下载setup文件。

#!/usr/bin/pythonimport MySQLdbdef doInsert(cursor,db):  #insert  # Prepare SQL query to INSERT a record into the database.  sql = "UPDATE EMPLOYEE SET AGE = AGE+1 WHERE SEX = '%c'" %('M')  try:    cursor.execute(sql)    db.commit()  except:    db.rollback()def do_query(cursor,db):  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 'resuts',cursor.rowcount     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"def do_delete(cursor,db):  sql = 'DELETE FROM EMPLOYEE WHERE AGE > {}'.format(20)  try:    cursor.execute(sql)    db.commit()  except:    db.rollback()def do_insert(cursor,db,firstname,lastname,age,sex,income):  sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \       LAST_NAME, AGE, SEX, INCOME) \       VALUES ('%s', '%s', '%d', '%c', '%d' )" % \       (firstname,lastname,age,sex,income)  try:    cursor.execute(sql)    db.commit()  except:    db.rollback()# Open database connection# change this to your mysql account#connect(server,username,password,db_name)db = MySQLdb.connect("localhost","hunter","hunter","pydb" )# prepare a cursor object using cursor() methodcursor = db.cursor()do_query(cursor,db)doInsert(cursor,db)do_query(cursor,db)do_delete(cursor,db)do_query(cursor,db)do_insert(cursor,db,'hunter','xue',22,'M',2000)do_insert(cursor,db,'mary','yang',22,'f',5555)do_insert(cursor,db,'zhang','xue',32,'M',5000)do_insert(cursor,db,'hunter','xue',22,'M',333)do_query(cursor,db)# disconnect from serverdb.close()

评论关闭