本文共 2748 字，大约阅读时间需要 9 分钟。
使用python获取mysql相关信息，使用python执行mysql相关语句
test1#!/bin/env python#coding=utf-8#by songry#date 2018-01-09#time 11:18#power databaseimport pymysql# 打开数据库连接（ip/数据库用户名、登录密码、数据库名）db = pymysql.connect("ipxx","userroot","passwd","dbname")#使用 cursor() 方法创建一个游标对象 cursorcursor = db.cursor()##############################################获取单条数据######使用execute（）方法执行sql查询cursor.execute("SELECT aaa.* from xxx")#使用fetchone（）方法获取单条数据data = cursor.fetchone()print data##目前只能获取单条数据############################# 若多条数据 #############使用execute（）方法执行sql查询#获取表中有多少数据aa=cursor.execute("SELECT aaa.ip_address from xx;")print aa#打印表中的多少数据info=cursor.fetchmany(aa)for ii in info: print ii###########################################################关闭游标#cursor.close()#提交数据，增删等操作，若不提交，数据不会真的变更#db.commit()#关闭数据库db.close()############# test2
#####fetchmany(aa) =>变成 fetchall() ， feichone 单条数据#!/bin/env python#coding=utf-8#by songry#date 2018-01-09#time 11:18#power databaseimport pymysql# 打开数据库连接（ip/数据库用户名、登录密码、数据库名）db = pymysql.connect("ip","root","passwd","dbname")#使用 cursor() 方法创建一个游标对象 cursorcursor = db.cursor()#获取表中有多少数据aa=cursor.execute("SELECT aaa.ip_address,ccc.username from xxxx;")print aa#打印表中的多少数据info=cursor.fetchall()for ii in info:# print ii ip = ii[0] name = ii[1] print ("ip is %s,name is %s" % (ip,name))#cursor.close()#db.commit()#关闭数据库db.close() test 3
#####add try ; 与数据库变更，需要 db.commit#!/bin/env python#coding=utf-8#by songry#date 2018-01-09#time 11:18#power databaseimport pymysql# 打开数据库连接（ip/数据库用户名、登录密码、数据库名）db = pymysql.connect("ipxx","username","passwd","dbnamexx")#使用 cursor() 方法创建一个游标对象 cursorcursor = db.cursor()#sqlSQL="SELECT aaa.ip_address,ccc.username from xxx;"##########查询数据库try: #执行sql cursor.execute(SQL) #获取所有记录列表 info=cursor.fetchall() for ii in info:# print ii ip = ii[0] name = ii[1] print ("ip is %s,name is %s" % (ip,name))except: print("ERROR: unable to fetch xx")#关闭数据库db.close()################变更数据库sql = "UPDATE user SET name = 'xxx' WHERE ip = xxxxx" try: # 执行SQL语句 cursor.execute(sql) # 提交到数据库执行 db.commit() except: # 发生错误时回滚 db.rollback() # 关闭数据库连接 db.close() test 4
#!/bin/env python#coding=utf-8#by songry#date 2018-01-09#time 11:18#power databaseimport pymysql# 打开数据库连接（ip/数据库用户名、登录密码、数据库名）db = pymysql.connect("ipxx","xxx","passwdxx","dbnamexx")#使用 cursor() 方法创建一个游标对象 cursorcursor = db.cursor()#sqlSQL="SELECT aaa.ip_address,ccc.username from xxxxx;"try: #执行sql cursor.execute(SQL) #获取所有记录列表 info=cursor.fetchall() for ip,name in info: print ("ip is %s,name is %s" % (ip,name))# print (ip,name)except: print("ERROR: unable to fetch xx")#关闭数据库db.close() 转载于:https://blog.51cto.com/sry2004/2059368