使用python获取mysql相关信息,使用python执行mysql相关语句
test1
#!/bin/env python
#coding=utf-8
#by songry
#date 2018-01-09
#time 11:18
#power database
import pymysql
# 打开数据库连接(ip/数据库用户名、登录密码、数据库名)
db = pymysql.connect("ipxx","userroot","passwd","dbname")
#使用 cursor() 方法创建一个游标对象 cursor
cursor = 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 database
import pymysql
# 打开数据库连接(ip/数据库用户名、登录密码、数据库名)
db = pymysql.connect("ip","root","passwd","dbname")
#使用 cursor() 方法创建一个游标对象 cursor
cursor = 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 database
import pymysql
# 打开数据库连接(ip/数据库用户名、登录密码、数据库名)
db = pymysql.connect("ipxx","username","passwd","dbnamexx")
#使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()
#sql
SQL="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 database
import pymysql
# 打开数据库连接(ip/数据库用户名、登录密码、数据库名)
db = pymysql.connect("ipxx","xxx","passwdxx","dbnamexx")
#使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()
#sql
SQL="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()