python操作数据库

来源:http://www.pykjg.com 作者:一分快三平台 人气:186 发布时间:2019-12-27
摘要:   数据库编制程序 早先方我们精晓数据库概念包蕴数据库文件、服务器和数据库客商端客商端大家以前已经用过的有navicat/mysql-client等程序。 主题材料:如何利用客商端将100000行数据插

 


 数据库编制程序

早先方我们精晓数据库概念包蕴数据库文件、服务器和数据库客商端 客商端大家以前已经用过的有navicat/mysql-client等程序。

主题材料: 如何利用客商端将100000行数据插入到数据库?

我们会意识只要用事前顾客端大致是不恐怕完全那么些义务的, 因为大家不容许去协会出十二分插入10w行数据的SQL。可是,假诺大家有贰个成效能够插入大器晚成行数据,依据程序强盛的表征-重复,就能够一挥而就的就将10w行数据收入麾下。这种经过使用程序代码的方法去老是数据库服务器,通过和服务器进行交互实现对数据库的增加和删除改查的办法,就叫做数据库编制程序。

而此时攻读的pymysql正是风度翩翩种客商端。

 Python 中操作 MySQL 步骤

怎么样精通连接 connection 和 游标 cursor connection仿佛连接出发地和目标地的 高品级公路cursor就如在一级公路上的卡车-拉货 大家应用游标就足以达成对数码的操作 当大家做到操作完结后就足以告生龙活虎段落卡车,然后公路再甘休使用。

pymysql的使用

引进模块

from pymysql import connect

Connection 对象

  • 用于建构与数据库的连天 调用pymysql模块中的connect(卡塔尔国方法
conn=connect(参数列表)

* 参数host:连接的mysql主机,如果本机是'localhost'
* 参数port:连接的mysql主机的端口,默认是3306
* 参数database:数据库的名称
* 参数user:连接的用户名
* 参数password:连接的密码
* 参数charset:通信采用的编码方式,推荐使用utf8
  • 关门连接 conn.close()

  • 交给数据 conn.commit()

  • 注销数据 conn.rollback()

  • 通过连接获取游标 cur = conn.cursor()再次回到Cursor对象,用于实践sql语句并获得结果

Cursor游标对象

  • 获取Cursor对象

      # 调用Connection对象的cursor()方法    
      cur =conn.cursor()
    

目标: 执行sql语句(使用频度最高的口舌为select、insert、update、delete卡塔尔(قطر‎

  • 运用游标实行SQL语句

execute(operation [, parameters ]) 试行SQL语句,重回受影响的行数,首要用以试行insert、update、delete语句,也能够实行create、alter、drop等话语

  • 关闭游标 cur.close()
  • 收获结果聚焦的一条

    cur.fetchone()回去一个元组 形如 (1,'苏妲己',18卡塔尔(英语:State of Qatar)

  • 获取结果聚焦的富有

    cur.fetchall()实施查询时,获取结果集的装有行,意气风发行构成叁个元组,再将那几个元组装入叁个元组返回形如((1,'公孙离',20卡塔尔,(2,'苏妲己',18卡塔尔国卡塔尔(英语:State of Qatar)

pymysql达成多少查询

import pymysql

# 创建和数据库服务器的连接 服务器地址   端口    用户名     密码  数据库名 通信使用字符和数据库字符集一致
conn = pymysql.connect(host='localhost', port=3306, user='root', password='mysql',database='python_test_1', charset='utf8')

# 获取游标
cursor = conn.cursor()

# 执行SQL语句 返回值就是SQL语句在执行过程中影响的行数
sql = """select * from hero;"""

row_count = cursor.execute(sql)
print("SQL语句执行影响的行数%d" % row_count)

# 取出结果集中一行  返回的结果是一行 (1, '妲己', 2)
# print(cursor.fetchone())

# 取出结果集中的所有数据  返回 ((一行数据),(),())
# ((1, '妲己', 2), (2, '李白', 1), (3, '程咬金', 3), (4, '亚瑟', 5), (5, '荆轲', 99))
for line in cursor.fetchall():
    print(line)

# 关闭游标
cursor.close()

# 关闭连接
conn.close()

pymysql实现对数据库的增加和删除改

import pymysql

conn = pymysql.connect(host='127.0.0.1',port=3306,user='root',password='mysql',db='python_test_1', charset='utf8')

# 通过连接获取游标
cursor = conn.cursor()


# sql = "delete from hero where id = 5;"
# sql = insert into hero (name) values ('西部大坏蛋孙悟空');
sql = "update hero set kongfuid=444 where id = 4;"

row_count = cursor.execute(sql)
print("SQL语句执行影响的行数%d" % row_count)

# 提交数据到数据库
# conn.commit()

# 回滚数据到什么都不做的状态 即撤销刚刚的修改
conn.rollback()

# 关闭游标和连接
cursor.close()
conn.close()

至于提交commit commit将修正提交到数据库,保存修正

style="font-size: 14px">注意pymysql中多少要求手动提交commit技术保存到数据库中

参数化列表防止SQL注入

怎么是SQL注入 爆发原因: 后台将客户提交的包涵恶意的数量和SQL进行字符串方式的拼凑,进而影响了SQL语句的语义,最后爆发多少外泄的情景。 要是幸免: sql语句的参数化, 将SQL语句的具备数据参数存在多个列表中传递给execute函数的第三个参数

注意

* 此处不同于python的字符串格式化,必须全部使用%s占位
* 所有参数所需占位符外不需要加引号
from pymysql import connect

def main():

    find_name = input("请输入物品名称:")

    # 创建Connection连接
    conn = connect(host='localhost',port=3306,user='root',password='mysql',database='jing_dong',charset='utf8')
    # 获得Cursor对象
    cs1 = conn.cursor()


    # # 非安全的方式
    # # 输入 " or 1=1 or "   (双引号也要输入)
    # sql = 'select * from goods where name="%s"' % find_name
    # print("""sql===>%s<====""" % sql)
    # # 执行select语句,并返回受影响的行数:查询所有数据
    # count = cs1.execute(sql)

    # 安全的方式
    # 构造参数列表 
    params = [find_name]
    # 执行select语句,并返回受影响的行数:查询所有数据
    count = cs1.execute('select * from goods where name=%s', params)
    # 注意:
    # 如果要是有多个参数,需要进行参数化
    # 那么params = [数值1, 数值2....],此时sql语句中有多个%s即可 

    # 打印受影响的行数
    print(count)
    # 获取查询的结果
    # result = cs1.fetchone()
    result = cs1.fetchall()
    # 打印查询的结果
    print(result)
    # 关闭Cursor对象
    cs1.close()
    # 关闭Connection对象
    conn.close()

if __name__ == '__main__':
    main()

本文由一分快三平台发布于一分快三平台,转载请注明出处:python操作数据库

关键词:

上一篇:没有了

下一篇:没有了

最火资讯