首页 / PYTHON / python pymysql操作数据库

python pymysql操作数据库

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了python pymysql操作数据库，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含5201字，纯文字阅读大概需要8分钟。

内容图文

            import
             pymysql



            def
             creatDB(dbName):
    
            """
            
    dbName：数据库名称
    创建数据库
    
            """
            
    conn = pymysql.connect(host=‘localhost‘, port=3306, user=‘root‘, password=‘root‘, charset=‘utf8‘)
    myCursor = conn.cursor()
    myCursor.execute("CREATE DATABASE {}".format(str(dbName)))
    myCursor.close()
    conn.close()


def creatTable(dbName, tableName):
    """
    dbName：数据库名称
    tableName：表名称
    创建表
    """
    conn = pymysql.connect(
        host=‘localhost‘,
        port=3306,
        user=‘root‘,
        password=‘root‘,
        database=str(dbName),
        charset=‘utf8‘
    )
    myCursor = conn.cursor()
    sql = "CREATE TABLE {} (""id INT NOT NULL AUTO_INCREMENT PRIMARY KEY, ""name VARCHAR(255) UNIQUE, ""age TINYINT DEFAULT NULL, ""gender boolean DEFAULT FALSE, ""testText TEXT, ""img mediumblob DEFAULT NULL)".format(str(tableName))
    myCursor.execute(sql)
    myCursor.close()
    conn.close()


def getAllTables(dbName):
    """
    dbName：数据库名称
    tableName：表名称
    dataDic：一个字典，键是表的字段，值是要插入的值
    获取所有的表名称，返回值是一个包含所有表名称的列表
    """
    tableList = []
    conn = pymysql.connect(host=‘localhost‘, port=3306, user=‘root‘, password=‘root‘, database=str(dbName),
                           charset=‘utf8‘)
    myCursor = conn.cursor()
    myCursor.execute("show tables")
    tableNames = myCursor.fetchall()
    for tableName in tableNames:
        tableList.append(tableName[0])
    myCursor.close()
    conn.close()

    return tableList


def insertIntoTable(dbName, tableName, dataDic):
    """
    dbName：数据库名称
    tableName：表名称
    dataDic：一个字典，键是表的字段，值是要插入的值
    往数据库里插入一条数据
    """
    conn = pymysql.connect(host=‘localhost‘, port=3306, user=‘root‘, password=‘root‘, database=str(dbName),
                           charset=‘utf8‘)
    myCursor = conn.cursor()

    keys = ‘, ‘.join(dataDic.keys())
    values = ‘, ‘.join([‘%s‘] * len(dataDic))
    sql = ‘INSERT INTO {table} ({keys}) VALUES ({values})‘.format(table=tableName, keys=keys, values=values)
    try:
        if myCursor.execute(sql, tuple(dataDic.values())):
            print(‘插入数据成功‘)
            conn.commit()
            lastID = myCursor.lastrowid

            return lastID

    except Exception as e:
        print(e)
        print(‘插入数据失败‘)
        conn.rollback()
    finally:
        myCursor.close()
        conn.close()


def updateIntoTable(dbName, tableName, dataDic):
    """
    dbName：数据库名称
    tableName：表名称
    dataDic：一个字典，键是表的字段，值是要插入的值
    如果数据库里面有这条数据，就对这条数据进行修改操作，如果没有，就增加一条数据，进行修改操作时，ID不变。
    返回值是最新插入数据的ID或被修改数据的原ID。
    """

    conn = pymysql.connect(host=‘localhost‘, port=3306, user=‘root‘, password=‘root‘, database=str(dbName),
                           charset=‘utf8‘)
    myCursor = conn.cursor()
    keys = ‘, ‘.join(dataDic.keys())
    values = ‘, ‘.join([‘%s‘] * len(dataDic))
    sql = ‘INSERT INTO {table}({keys}) VALUES ({values}) ON DUPLICATE KEY UPDATE‘.format(table=tableName, keys=keys,
                                                                                         values=values)
    update = ‘,‘.join([" {key} = %s".format(key=key) for key in dataDic])
    sql += update
    try:
        if myCursor.execute(sql, tuple(dataDic.values()) * 2):
            print(‘插入数据成功‘)
            conn.commit()
            lastID = myCursor.lastrowid

            return lastID

    except Exception as e:
        print(e)
        print(‘插入数据失败‘)
        conn.rollback()
    finally:
        myCursor.close()
        conn.close()


def replaceIntoTable(dbName, tableName, dataDic):
    """
    dbName：数据库名称
    tableName：表名称
    dataDic：一个字典，键是表的字段，值是要插入的值
    如果数据库里面有这条数据，先删除原来的数据在进行增加，如果没有，就增加一条数据，ID改变。
    返回值是最新插入数据的ID。
    """
    conn = pymysql.connect(host=‘localhost‘, port=3306, user=‘root‘, password=‘root‘, database=str(dbName),
                           charset=‘utf8‘)
    myCursor = conn.cursor()

    keys = ‘, ‘.join(dataDic.keys())
    values = ‘, ‘.join([‘%s‘] * len(dataDic))
    sql = ‘REPLACE INTO {table} ({keys}) VALUES ({values})‘.format(table=tableName, keys=keys, values=values)
    try:
        if myCursor.execute(sql, tuple(dataDic.values())):
            print(‘插入数据成功‘)
            conn.commit()
            lastID = myCursor.lastrowid

            return lastID

    except Exception as e:
        print(e)
        print(‘插入数据失败‘)
        conn.rollback()
    finally:
        myCursor.close()
        conn.close()


def delData(dbName, tableName, condition):
    """
    dbName：数据库名称
    tableName：表名称
    condition：删除的条件
    删除数据
    """
    conn = pymysql.connect(host=‘localhost‘, port=3306, user=‘root‘, password=‘root‘, database=str(dbName),
                           charset=‘utf8‘)
    myCursor = conn.cursor()
    sql = ‘DELETE FROM {table} WHERE {condition}‘.format(table=tableName, condition=condition)
    try:
        if myCursor.execute(sql):
            print(‘删除数据成功‘)
            conn.commit()
    except Exception as e:
        print(e)
        print(‘删除数据失败‘)
        conn.rollback()
    finally:
        myCursor.close()
        conn.close()


def selectDataAll(dbName, tableName):
    """
    dbName：数据库名称
    tableName：表名称
    查询所有的数据
    """
    conn = pymysql.connect(host=‘localhost‘, port=3306, user=‘root‘, password=‘root‘, database=str(dbName),
                           charset=‘utf8‘)
    myCursor = conn.cursor()
    sql = ‘SELECT * FROM {table}‘.format(table=tableName)
    if myCursor.execute(sql):
        allData = myCursor.fetchall()
        return allData
    else:
        return None


def selectDataOne(dbName, tableName):
    """
    dbName：数据库名称
    tableName：表名称
    查询第一条数据
    """
    conn = pymysql.connect(host=‘localhost‘, port=3306, user=‘root‘, password=‘root‘, database=str(dbName),
                           charset=‘utf8‘)
    myCursor = conn.cursor()
    sql = ‘SELECT * FROM {table}‘.format(table=tableName)
    if myCursor.execute(sql):
        oneData = myCursor.fetchone()
        return oneData
    else:
        return None


def selectDataMany(dbName, tableName, size):
    """
    dbName：数据库名称
    tableName：表名称
    size：想要查询的数据 int类型
    查询多条数据
    """
    conn = pymysql.connect(host=‘localhost‘, port=3306, user=‘root‘, password=‘root‘, database=str(dbName),
                           charset=‘utf8‘)
    myCursor = conn.cursor()
    sql = ‘SELECT * FROM {table}‘.format(table=tableName)
    if myCursor.execute(sql):
        manyData = myCursor.fetchmany(size)
        return manyData
    else:
        return None

原文：https://www.cnblogs.com/crazywh/p/13688087.html

内容总结

以上是互联网集市为您收集整理的python pymysql操作数据库全部内容，希望文章能够帮你解决python pymysql操作数据库所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1275037.html

来源：【匿名】

【上一篇】python之ftp作业【还未完成】【下一篇】浅谈PHP运行Python脚本的方法

更多 ►

【python pymysql操作数据库】教程文章相关的互联网学习教程文章

python pymysql操作数据库【代码】

import pymysqldef creatDB(dbName):"""dbName：数据库名称创建数据库"""conn = pymysql.connect(host=‘localhost‘, port=3306, user=‘root‘, password=‘root‘, charset=‘utf8‘)myCursor = conn.cursor()myCursor.execute("CREATE DATABASE {}".format(str(dbName)))myCursor.close()conn.close()def creatTable(dbName, tableName):"""dbName：数据库名称tableName：表名称创建表"""conn = pymysql.connect(host=‘localh...

在 ubuntu 中安装 python3.5 tornado pymysql【图】

一、在 ubuntu 中安装 python3.5 1、首先，在系统中是自带python2.7的。不要卸载，因为一些系统的东西是需要这个的。python2.7和python3.5是可以共存的。命令如下(已经在阿里云的ubuntu中测试)：apt-get install Python-software-properties apt-get install software-properties-common sudo add-apt-repository ppa:fkrull/deadsnakes //add-apt-repository 是需要上方2个包支持的。 sudo apt-get update sudo apt-get install ...

python-pymysql【代码】

1.基本用法 import pymysql #建立连接 conn=pymysql.connect(host=‘localhost‘,port=3306,user=‘root‘,password=‘123456‘,db=‘mydb‘ ) #创建游标 cursor=conn.cursor() #执行sql effect_row=cursor.execute("select * from student") #查询第一行 #row_1=cursor.fetchone() #print(row_1) #查询全部 row_all=cursor.fetchall() print(row_all)conn.commit() cursor.close() conn.close()原文：http://blog.51cto.com/13803...

Python3.7.1学习（七）mysql中pymysql模块详解(一)【代码】【图】

pymysql是纯用Python操作MySQL的模块，其使用方法和MySQLdb几乎相同。此次介绍mysql以及在python中如何用pymysql操作数据库, 以及在mysql中存储过程, 触发器以及事务的实现, 对应到pymysql中应该如何操作。　　一、创建连接　　　　1.准备工作，想要使用Python操作MySQL，可以使用pip方式安装：pip install PyMySQL 2.Python使用MySQL的流程： 3.Python中使用MySQL导入方法： import pymysql 4...

mysql python pymysql模块获取插入的最后一条数据的自增ID lastrowid()方法【代码】

调用游标下的lastrowid 可以获取插入之前的表里id字段存放到哪个自增idcursor.lastrowidmysql> select * from userinfo; +----+-------+-----+ | id | name | pwd | +----+-------+-----+ | 1 | mike | 123 | | 2 | jack | 456 | | 3 | alex | 555 | | 4 | peter | 989 | | 5 | app | 123 | | 6 | tom | 556 | +----+-------+-----+ 6 rows in set (0.03 sec)我再用脚本插入三条记录自增id就是从 7开始，获取我插入...

Python Pymysql【代码】

1.1 Pymysql安装与简介1. 安装pip3 install pymysql2、介绍（支持python3）1. pymsql是Python中操作MySQL的模块，其使用方法和MySQLdb几乎相同2. 我们可以使用pymysql使用原生sql语句操作数据库3、使用root连接时必须先对root用户授权不然会报错mysql> grant all on *.* to 'root'@'%' identified by '1';mysql> flush privileges;1.2 pymysql基本使用1、原生SQL语句创建数据库和表create table student(id int auto_increment,nam...

【转】Python中操作mysql的pymysql模块详解

Python中操作mysql的pymysql模块详解前言pymsql是Python中操作MySQL的模块，其使用方法和MySQLdb几乎相同。但目前pymysql支持python3.x而后者不支持3.x版本。本文测试python版本：2.7.11。mysql版本：5.6.24一、安装1pip3 install pymysql二、使用操作1、执行SQL1234567891011121314151617181920212223242526#!/usr/bin/env pytho# -*- coding:utf-8 -*-importpymysql # 创建连接conn =pymysql.connect(host=‘127.0.0.1‘, port=...

python3操作PyMySQL笔记【代码】

python3操作mysql需要先安装PyMySQLpip install PyMySQL在linux登录mysql ，并且在安装数据库时设置了数据库的用户名“root”和密码“root”，mysql安装的版本为mysql5.7[root@web ~]# mysql -uroot -p -h192.168.10.100在mysql里面创建一个mysql库mysql>createdatabase mrsoft; Query OK, 1 row affected (0.00 sec)下面是新建一个py文件远程创建一个mysql连接，下面通过connect()方法连接MySQL数据库mrsoft，具体代码如下：impor...

python---pymysql【代码】

pymysql是Python中操作MySQL的模块，其使用方法和MySQLdb几乎相同。2.7用MySQLdb，3.0用pymysql。#下载安装 pip3 install pymysql使用执行SQL#!/usr/bin/env python # -*- coding:utf-8 -*- import pymysql# 创建连接 conn = pymysql.connect(host=‘127.0.0.1‘, port=3306, user=‘root‘, passwd=‘123‘, db=‘t1‘) # 创建游标 cursor = conn.cursor()# 执行SQL，并返回收影响行数 effect_row = cursor.execute("update hosts...

Python中pymysql基本使用【代码】

Python中pymysql模块通过获取mysql数据库命令行游标执行数据库命令来进行数据库操作　　优点：操作数据库语句所见即所得，执行了什么数据库语句都很清楚　　缺点：操作繁琐，代码量多 1. pymysql的基本使用# -*- coding:utf-8 -*- # Author:Wong Duimport pymysql# 创建链接，相当于建立一个socket conn = pymysql.Connection(host=‘10.0.0.100‘, port=3306, user=‘root‘, passwd=‘123456‘, db=‘testdb‘)# 建立游标，相当...

Python连接MySQL数据库之pymysql模块使用【代码】

Python3连接MySQL本文介绍Python3连接MySQL的第三方库--PyMySQL的基本使用。PyMySQL介绍PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库，Python2中则使用mysqldb。Django中也可以使用PyMySQL连接MySQL数据库。PyMySQL安装pip install pymysql连接数据库注意事项在进行本文以下内容之前需要注意：你有一个MySQL数据库，并且已经启动。你有可以连接该数据库的用户名和密码你有一个有权限操作的database基本使用# 导入p...

Python3操作MySQL基于PyMySQL封装的类【代码】

Python3操作MySQL基于PyMySQL封装的类??在未使用操作数据库的框架开发项目的时候，我们需要自己处理数据库连接问题，今天在做一个Python的演示项目，写一个操作MySQL数据库的类，基于PyMySQL库在Python3上实现。在写业务逻辑代码的时候，可以方便很多，时间关系，没有写太完善，只写了常用的操作。??直接上代码：#!/usr/bin/env python # -*- coding: utf-8 -*-'Python连接到 MySQL 数据库及相关操作(基于Python3)'import pymysql....

python模块pymysql

基本操作：（1）导入pymysql: import pymysql （2）连接数据库： conn=pymysql.connect(host=‘localhost‘,user=‘root‘,passwd=‘root‘,db=‘ere‘，charset=‘utf8‘) 务必注意各等号前面的内容！charset参数可避免中文乱码（3）获取操作游标：cur=conn.cursor()（4）执行sql语句,插入记录：sta=cur.execute("insert 语句") 执行成功后sta值为1。更新、删除语句与此类似。（5）执行sql语句，查询记录：cur.execute("selec...

mysql python pymysql模块增删改查插入数据介绍 commit() execute() executemany() 函数【代码】

import pymysqlmysql_host = ‘192.168.0.106‘ port = 3306 mysql_user = ‘root‘ mysql_pwd = ‘123‘ encoding = ‘utf8‘# 建立连接mysql服务端 conn = pymysql.connect(host=mysql_host, # mysql服务端ipport=port, # mysql端口user=mysql_user, # mysql 账号password=mysql_pwd, # mysql服务端密码db=‘db10‘, # 操作的库charset=encoding # 读取字符串编码 )# 拿到游标对象 cur = conn.cursor()‘‘‘ 游标是给mys...

django1.7.1+python3.3+pymysql搭建

安装django，python，pymysqlsetting.py文件配置按照平常连接使用mysqldb的配置，重点是此目录下的__init__文件添加import pymysqlpymysql.install_as_MySQLdb()检查INSTALL_APPS配置是否有两个admin的配置，注释一个，否则创建app时报错原文：http://4620226.blog.51cto.com/4610226/1606158

首页 / PYTHON / python pymysql操作数据库

python pymysql操作数据库

内容导读

内容图文

内容总结

内容备注

内容手机端

【python pymysql操作数据库】教程文章相关的互联网学习教程文章

PYMYSQL - 相关标签

PYTHON - 技术教程分类

PYTHON - 最新教程

PYTHON - 最热教程