诛仙全本下载:[Python]Python连接MySQL (例子)

来源:百度文库 编辑:九乡新闻网 时间:2024/04/27 06:19:35
  1. """
  2.  ***** This is a MySQL test *****
  3.  
  4.  select:
  5.   conn=Connection()
  6.   conn.select_db('test')
  7.   cur=conn.cursor()
  8.   cur.execute('select * from user')
  9.   cur.scroll(0)
  10.   row1=cur.fetchone()
  11.   row1[0]
  12.   row1[1]
  13.   row1[2]
  14.  insert:
  15.   cur.execute('insert into user (name,passwd) values(\'benyur\',\'12345\')')
  16.   cur.insert_id()
  17.  
  18.  update:
  19.   cur.execute('update user set passwd=\'123456\' where name=\'benyur\'')
  20.  
  21.  delete:
  22.   cur.execute('delete from user where id=2')
  23.  
  24.  **********************************
  25. """

#以上““““““中间的部分就是本模块的__doc__的内容

  1. from MySQLdb import *                    #导入MySQLdb模块
  2.  
  3. def conn():                                      #定义conn函数
  4.  conn=Connection()                          #打开连接
  5.  conn.select_db('test')                       #选择数据库
  6.  cur=conn.cursor()                           #取得游标
  7.  cur.execute('select * from user')      #执行查询语句
  8.  cur.scroll(0)                                    #滚动游标到头
  9.  row1=cur.fetchone()                        #取得一行,row1是一个列表
  10.  row1[0]
  11.  row1[1]
  12.  row1[2]
  13.  
  14. def usage():                                   #定义打印用法函数
  15.  print __doc__                                #打印内部属性__doc__,即上面的““““““中间的部分
  16.  
  17. if __name__=='__main__':             #如果是主程序运行(不是导入模块)
  18.  usage()                                        #打印用法
  19. import MySQLdb
  20. conn=MySQLdb.Connect(host='localhost',user='root',passwd='111111')
  21. curs=conn.cursor()
  22. try:
  23.     curs.execute('drop database etcdb')
  24.     print "database alrealdy exist,delete this database!"
  25. except:
  26.     print "database not exist,create this database!"
  27.     pass #did not exist
  28. curs.execute('create database etcdb')
  29. print "create new database!"
  30. curs.execute('use etcdb')
  31. print "use new database"
  32. curs.execute('create table users (name char(30),password char(20))')
  33. print "create new table"
  34. curs.execute('insert users values (%s,%s)',('honggou','honggou'))
  35. curs.execute('insert users values (%s,%s)',('wurui','wurui'))
  36. curs.execute('insert users values (%s,%s)',('mengle','mengle'))
  37. curs.execute('insert users values (%s,%s)',('lidai','lidai'))
  38. curs.execute('insert users values (%s,%s)',('111','111'))
  39. print "insert values to table"
  40.  
  41. curs.execute('select * from users')
  42. for row in curs.fetchall():
  43.     print row
  44.  
  45. curs.execute('select * from users')
  46. colnames=[desc[0] for desc in curs.description]
  47. while True:
  48.     print '-'*30
  49.     row=curs.fetchone()
  50.     if not row:break
  51.     for (name,value) in zip(colnames,row):
  52.         print '%s =>> %s' % (name,value)
  53.  
  54. conn.commit()