Python MySQL進行數據庫表變更和查詢

這篇文章主要介紹了python mysql進行數據庫表變更和查詢的相關資料,需要的朋友可以參考下

python連接MySQL,進行數據庫表變更和查詢:

python mysql insert delete query:

#!/usr/bin/python?  ?  import?MySQLdb?  def?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","root","root","pydb"?)?  #?prepare?a?cursor?object?using?cursor()?method?  cursor?=?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?server?  db.close()

之后可以在此基礎上根據需要進行封裝。

? 版權聲明
THE END
喜歡就支持一下吧
點贊15 分享