澳门新莆京手机网站-新蒲京娱乐场 > 澳门新莆京手机网站 > Python 与数据库人机联作

Python 与数据库人机联作

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语句并获得结果

  MySQLdb 是用来 Python 连接 MySQL 数据库的接口,它完结了 Python 数据库 API 标准 V2.0,基于 MySQL C API 上创立的。

取多行数据

第二步   Connection对象

1.用来建设构造与数据库的接连几日

2.创立对象:调用connect(卡塔尔(قطر‎方法

● 参数host:连接的mysql主机,假若本机是'localhost'

● 参数port:连接的mysql主机的端口,暗许是3306

● 参数db:数据库的名目

● 参数user:连接的客商名

● 参数password:连接的密码

● 参数charset:通讯接收的编码方式,暗中同意是'gb2312',必要与数据库创设时钦点的编码少年老成致,不然普通话会乱码

比方:conn = pymysql.connect(host='127.0.0.1', port=3306, user='顾客名', passwd='密码', db='数据库名',charset="utf8"卡塔尔国

 数据库编制程序

从日前大家领略数据库概念包蕴数据库文件、服务器和数据库客商端 顾客端大家事前曾经用过的有navicat/mysql-client等前后相继。

题目: 怎么样行使客户端将100000行数据插入到数据库?

世家会意识只要用事情发生早先客商端大致是不只怕完全那么些任务的, 因为大家不容许去协会出十三分插入10w行数据的SQL。不过,如若我们有三个意义能够插入生机勃勃行数据,依附程序强盛的特色-重复,就足以一挥而就的就将10w行数据收入麾下。这种经过接纳程序代码的办法去老是数据库服务器,通过和服务器实行交互作用完毕对数据库的增加和删除改查的点子,就称为数据库编制程序。

而这个时候求学的pymysql就是风流罗曼蒂克种顾客端。

import pymysql  
  
# 展开数据库连接(ip/数据库顾客名/登入密码/数据库名)  
db = pymysql.connect("localhost", "root", "root", "test")  
# 使用 cursor(卡塔尔国 方法创制五个游标对象 cursor  
cursor = db.cursor()  
  
# SQL 更新语句  
sql = "UPDATE user SET name = 'Bob' WHERE id = 1"  
try:  
    # 执行SQL语句  
    cursor.execute(sql)  
    # 提交到数据库施行  
    db.commit()  
except:  
    # 产生错误时回滚  
    db.rollback()  
     
# 关闭数据库连接  
db.close()  

# 必定要有固定的:获取Cursor对象

第四部   对数码举办操作

cur.execute("实践语句"卡塔尔国

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本事保存到数据库中

def createtable(db):
    # 使用cursor(卡塔尔(قطر‎方法获得操作游标 
    cursor = db.cursor()

cs.close()

(详解)

 


(1) 什么是MySQLdb?

# 打字与印刷重回的询问结果行数

指标的个性

● rowcount只读属性,表示近来一回execute(卡塔尔国推行后受影响的行数

● connection获得当前连连对象

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()

    #sql = "INSERT INTO Student(ID, Name, Grade)
    #    VALUES ('%s', '%s', '%d')" %
    #    ('001', 'HP', 60)
    try:
        # 执行sql语句
        cursor.execute(sql)
        # 提交到数据库执行
        db.commit()
    except:
        # Rollback in case there is any error
        print '插入数据失利!'
        db.rollback()

# 实施select语句,并再次回到查询的结果条数

第三步   cursor对象

1.执行sql语句

2.创造对象:调用Connection对象的cursor(卡塔尔国方法

例如:cur=conn.cursor()

参数化列表制止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()

def createtable(db):
    # 使用cursor(卡塔尔国方法赢得操作游标 
    cursor = db.cursor()

print

指标的措施

● close(卡塔尔关闭连接

● commit(卡塔尔(قطر‎事务,所以须求提交才会生效

● rollback(卡塔尔国事务,放任早先的操作

● cursor(State of Qatar重返Cursor对象,用于奉行sql语句并得到结果

pymysql的使用

引进模块

from pymysql import connect

$ tar zxvf MySQL-python-*.tar.gz
$ cd MySQL-python-*
$ python setup.py build
$ python setup.py install 

commit() 提交

指标的方法

● close()关闭

● execute(operation [, parameters ]卡塔尔国试行语句,重临受影响的行数

● fetchone(卡塔尔(قطر‎施行查询语句时,获取查询结果集的率先个行数据,重临二个元组

● next(卡塔尔(قطر‎试行查询语句时,获取当前进的下生龙活虎行

● fetchall(卡塔尔国实行查询时,获取结果集的富有行,生机勃勃行构成二个元组,再将那些元组装入叁个元组重返

● scroll(value[,mode]卡塔尔国将行指针移动到有些地点

                ○ mode表示移动的不二等秘书技

                ○ mode的默许值为relative,表示依据当前进活动到value,value为正则向下活动,value为负则向上移动

               ○ mode的值为absolute,表示遵照第一条数据的岗位,第一条数据的职分为0

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,'苏妲己',18State of Qatar

  • 获取结果聚集的装有

    cur.fetchall()施行查询时,获取结果集的具备行,后生可畏行构成二个元组,再将那个元组装入一个元组重临形如((1,'公孙离',20卡塔尔国,(2,'妲己',18卡塔尔国卡塔尔

    createtable(db)     # 创建表
    insertdb(db)        # 插入数据
    print 'n插入数据后:'
    querydb(db) 
    deletedb(db)        # 删除数据
    print 'n删除数据后:'
    querydb(db)
    updatedb(db)        # 更新数据
    print 'n更新数据后:'
    querydb(db)

conn.close()

第一步   安装引入模块

1.安装mysql模块(python3)

pip install pymysql

2.在文书中引进

import pymysql

 Python 中操作 MySQL 步骤

怎么精晓连接 connection 和 游标 cursor connection就如连接出发地和目标地的 高速公路cursor犹如在高速度公路上的运货汽车-拉货 大家采纳游标就足以做到对数码的操作 当大家成功操作达成后就足以告风流倜傥段落卡车,然后公路再停止使用。

def deletedb(db):
    # 使用cursor(卡塔尔方法获得操作游标 
    cursor = db.cursor()

2、对象的点子

完全步骤(比如卡塔尔(قطر‎

# 1 . 引包

import pymysql

# 2. 创设连接

conn = pymysql.connect(host='127.0.0.1', port=3306, user='顾客名', passwd='密码', db='数据库名',charset="utf8"卡塔尔(قطر‎

# 3 . 创设对象

cur = conn.cursor()

# 4 . 实施语句

cur.execute("delete from user where id=1")

# 5 . 提交

conn.commit(卡塔尔(قطر‎ 提交(除查询,需求付出数据。)

# 6 . 关闭连接

cur.close()

conn.close()


    closedb(db)         # 关闭数据库

安装:pip3 install pymysql

    createtable(db)     # 创建表
    insertdb(db)        # 插入数据
    print 'n插入数据后:'
    querydb(db) 
    deletedb(db)        # 删除数据
    print 'n删除数据后:'
    querydb(db)
    updatedb(db)        # 更新数据
    print 'n更新数据后:'
    querydb(db)

for i in range:

查询后粤语会展现乱码,但在数据库中却是不荒谬的,发现用壹性子质有可消除:

参数port:连接mysql的端口,默认是3306

if __name__ == '__main__':
    main()











​#!/usr/bin/python  
#coding=utf-8  
  
import mysql.connector  
from mysql.connector import errorcode  
  
class mysqlconnectordemo(object):  
    def __init__(self):  
        pass  
    def connect(self,conf):  
        try:  
            conn = mysql.connector.connect(**conf)  
            print("conn success!")  
        except mysql.connector.Error as err:  
            if err.errno == errorcode.ER_ACCESS_DENIED_ERROR:  
                print("Something is wrong with your user name or password")  
            elif err.errno == errorcode.ER_BAD_DB_ERROR:  
                print("Database does not exist")  
            else:  
                print(err)  
        else:  
            conn.close()  
  
    def query(self,conf,sql):  
        try:  
            conn = mysql.connector.connect(**conf)  
            print("conn success!")  
            cursor = conn.cursor()  
            try:  
                cursor.execute(sql)  
                values = cursor.fetchall()#再次来到是多个由元组构成的list,每三个元组是生龙活虎行值  
                print type(values)  
                for i in values:  
                    print i  
            except mysql.connector.Error as err:  
                print('query datas error!{}'.format(err))  
        except mysql.connector.Error as err:  
            if err.errno == errorcode.ER_ACCESS_DENIED_ERROR:  
                print("Something is wrong with your user name or password")  
            elif err.errno == errorcode.ER_BAD_DB_ERROR:  
                print("Database does not exist")  
            else:  
                print(err)  
        else:  
            conn.close()  
  
    def insert(self,conf,sql):  
        try:  
            conn = mysql.connector.connect(**conf)  
            print("conn success!")  
            cursor = conn.cursor()  
            try:  
                cursor.execute(sql)  
                conn.commit()  
                cursor.close()  
            except mysql.connector.Error as err:  
                print('insert datas error!{}'.format(err))  
        except mysql.connector.Error as err:  
            if err.errno == errorcode.ER_ACCESS_DENIED_ERROR:  
                print("Something is wrong with your user name or password")  
            elif err.errno == errorcode.ER_BAD_DB_ERROR:  
                print("Database does not exist")  
            else:  
                print(err)  
        else:  
            conn.close()     

result1=fetchmany

    try:
       # 执行SQL语句
       cursor.execute(sql)
       # 提交修正
       db.commit()
    except:
        print '删除数据战败!'
        # 发生错误时回滚
        db.rollback()

1、创立Connection对象,用于创立与数据库的接二连三,创制对象调用connect(卡塔尔(قطر‎方法conn=connect

  1. mysql.connector 的使用

fetchone(卡塔尔国 实践查询语句时,获取查询结果集的第意气风发行数据,再次回到三个元祖

    # 如若存在表Sutdent先删除
    cursor.execute("DROP TABLE IF EXISTS Student")
    sql = """CREATE TABLE Student (
            ID CHAR(10) NOT NULL,
            Name CHAR(8),
            Grade INT )"""

cursor(卡塔尔(قطر‎ 重回Cursor对象,用于执行sql语句并拿走结果

import MySQLdb

main()

    #sql = "INSERT INTO Student(ID, Name, Grade)
    #    VALUES ('%s', '%s', '%d')" %
    #    ('001', 'HP', 60)
    try:
        # 执行sql语句
        cursor.execute(sql)
        # 提交到数据库实践
        db.commit()
    except:
        # Rollback in case there is any error
        print '插入数据退步!'
        db.rollback()

采取手续:

import pymysql  
  
# 展开数据库连接(ip/数据库顾客名/登陆密码/数据库名)  
db = pymysql.connect("localhost", "root", "root", "test")  
# 使用 cursor(卡塔尔 方法创制三个游标对象 cursor  
cursor = db.cursor()  
  
# SQL 插入语句  
sql = """INSERT INTO user(name) 
         VALUES ('Mac')"""  
try:  
   # 执行sql语句  
   cursor.execute(sql)  
   # 提交到数据库实践  
   db.commit()  
except:  
   # 若是发生错误则回滚  
   db.rollback()  
  
# 关闭数据库连接  
db.close()   

参数database:数据库名称

(3) 使用 mysql.connector:

"""

cursor用来实行命令的不二等秘书技:
callproc(self, procname, args卡塔尔(قطر‎:用来进行存款和储蓄进度,接纳的参数为存款和储蓄进度名和参数列表,再次来到值为受影响的行数
execute(self, query, args卡塔尔:实践单条sql语句,接受的参数为sql语句小编和使用的参数列表,重返值为受影响的行数
executemany(self, query, args卡塔尔(قطر‎:实行单挑sql语句,可是再一次实施参数列表里的参数,重回值为受影响的行数
nextset(self卡塔尔国:移动到下一个结出集

def main():

    # SQL 插入语句
    sql = """INSERT INTO Student
         VALUES ('001', 'CZQ', 70),
                ('002', 'LHQ', 80),
                ('003', 'MQ', 90),
                ('004', 'WH', 80),
                ('005', 'HP', 70),
                ('006', 'YF', 66),
                ('007', 'TEST', 100)"""

引进模块在python3里:from pymysql import *

    # 创建Sutdent表
    cursor.execute(sql)

close() 关闭

  1. PyMySQL 的使用

# 必定要有定点的:关闭cursor对象

上一篇:没有了 下一篇:MySQL高可用之PXC安装配置

Copyright © 2015-2019 http://www.carrefourstation.com. 澳门新莆京手机网站-新蒲京娱乐场有限公司 版权所有