增加一条数据
import pymysql
#返回Connection对象
#host="localhost"
con = pymysqlconnect(host="1921683128",
port=3306,user="atguigu",
password="atguigu",
db="atguigudb",
charset="utf8")
#返回cursor对象
cursor = concursor()
#SQL语言-SQL语句
sql = "insert into students(name) value('李四')"
#插入数据
cursorexecute(sql)
#提交数据,没有提交就没有数据
concommit()
#关闭释放资源
cursorclose()
#关闭资源
conclose()
修改数据
import pymysql#修改任意一条数据
#返回Connection对象
conn = pymysqlconnect(
host="1921683128",
db="atguigudb",
port=3306,
user="atguigu",
password="atguigu",
charset="utf8"
)
cursor = conncursor()
sql = "update students set name='郭靖' where id = 1"
count = cursorexecute(sql)
print("count=",count)
#提交正常数据物理上修改了
conncommit()
cursorclose()
connclose()
删除数据
import pymysql#修改任意一条数据
#返回Connection对象
conn = pymysqlconnect(
host="1921683128",
db="atguigudb",
port=3306,
user="atguigu",
password="atguigu",
charset="utf8"
)
cursor = conncursor()
sql = "delete from students where id =20"
count = cursorexecute(sql)
print("count=",count)
conncommit()
cursorclose()
connclose()
查询一条数据
import pymysqltry:
conn=pymysqlconnect(
host='1921683128',
port=3306,
db='atguigudb',
user='atguigu',
passwd='atguigu',
charset='utf8'
)
cursor=conncursor()
cursorexecute('select from students where id = 3')
#返回满足这个条件的这个数据,如果有多条返回第一条,并且封装元组中
result = cursorfetchone()
print(result)
for i in result:
print(i)
cursorclose()
connclose()
except Exception as e:
print(emessage)
查询多条数据
import pymysqltry:
conn=pymysqlconnect(
host='1921683128',
port=3306,
db='atguigudb',
user='atguigu',
passwd='atguigu',
charset='utf8'
)
cursor=conncursor()
cursorexecute('select from students')
#返回元组,如果多条数据,元组里面嵌套元组
result = cursorfetchall()
print(result)
for i in result:
print(i)
conncommit()
cursorclose()
connclose()
except Exception as e:
print(emessage)
读取mysql数据,填写数据到excel
from pyexcel_xls import save_datafrom pyexcel_xls import get_data
from collections import OrderedDict
import mysqlconnector
#和数据库建立连接
cnx =mysqlconnectorconnect(user='root', password='',
host='127001',
database='test')
#查询语句
sql = "select my_name,my_value from tbl_members "
#执行查询
cursorexecute(sql)
#获得查询结果
result = cursorfetchall()
cursorclose()
cnxclose()
#打开预定义表头文件
xls_header= get_data("d:/xhxls")
#获得表头数据
xh = xls_headerpop("Sheet1")
#拼接整表数据
xd = OrderedDict()
xdupdate({"Sheet 1":xh+result})
#保存到另一个文件中
save_data("d:/xdxls",xd)
本文实例为大家分享了Python读取MySQL数据库表数据的具体代码,供大家参考,具体内容如下
环境:Python 36 ,Window 64bit
目的:从MySQL数据库读取目标表数据,并处理
代码:
# -- coding: utf-8 --
import pandas as pd
import pymysql
## 加上字符集参数,防止中文乱码
dbconn=pymysqlconnect(
host="",
database="kimbo",
user="kimbo_test",
password="",
port=3306,
charset='utf8'
)
#sql语句
sqlcmd="select col_name,col_type,col_desc from itf_datadic_dtl_d limit 10"
#利用pandas 模块导入mysql数据
a=pdread_sql(sqlcmd,dbconn)
#取前5行数据
b=ahead()
print(b)
# 读取csv数据
# pdread_csv()
# 读取excel数据
#pdread_excel()
# 读取txt数据
#pdread_table()
结果如图:
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多
json的数据jsonloads进来以后会变成一个json的对象,你需要自己把python对象中的字段值取出来,拼成sql语句
你可以把这个过程封装成一个函数
import json
def save_json(json_str):
obj = jsonloads(json_str)
sql = 'insert into tbl values ("%s")' % obj['id'] #这里注意编码,要转成数据库的编码格式
#blabla
以上就是关于python使用数据库全部的内容,包括:python使用数据库、如何将mysql的数据读取python、python中 如何将从接口取到的json数据存入mysql数据库 最好有具体的例子 谢谢等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)