首页 / PYTHON / python3 使用pymysql

python3 使用pymysql

内容导读

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

内容图文

基本操作：
登陆：mysql -uroot -h127.0.0.1 -P3306 -p
mysql -uroot -p(本机不用写host)
退出mysql：ctrl+z+回车，或者exit
端口号默认是3306，但是可以通过安装目录下的配置文件修改。

#安装pymysql

pip3 install pymysql

#连接数据库

import pymysql
#打开数据库连接
conn = pymysql.connect('localhost',user = "root",passwd = "123456",db = "testdb")
#db = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='1234', db='testdb', charset='utf8')
print (conn)
print (type(conn))

#创建数据库

import pymysql
#打开数据库连接，不需要指定数据库，因为需要创建数据库
conn = pymysql.connect('localhost',user = "root",passwd = "123456")
#获取游标
cursor=conn.cursor()
#创建pythonBD数据库
cursor.execute('CREATE DATABASE IF NOT EXISTS pythonDB DEFAULT CHARSET utf8 COLLATE utf8_general_ci;')
cursor.close()#先关闭游标
conn.close()#再关闭数据库连接
print('创建pythonBD数据库成功')

#创建表

import pymysql
#打开数据库连接
conn = pymysql.connect('localhost',user = "root",passwd = "123456",db = "testdb")
#获取游标
cursor=conn.cursor()
print(cursor)

#创建user表
cursor.execute('drop table if exists user')
sql="""CREATE TABLE IF NOT EXISTS `user` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`name` varchar(255) NOT NULL,
`age` int(11) NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 AUTO_INCREMENT=0"""

cursor.execute(sql)
cursor.close()#先关闭游标
conn.close()#再关闭数据库连接
print('创建数据表成功')

#插入单条数据

import pymysql
#打开数据库连接，不指定数据库
conn=pymysql.connect('localhost','root','123456')
conn.select_db('pythondb')

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

#创建user表
cur.execute('drop table if exists user')
sql="""CREATE TABLE IF NOT EXISTS `user` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`name` varchar(255) NOT NULL,
`age` int(11) NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 AUTO_INCREMENT=0"""

cur.execute(sql)

insert=cur.execute("insert into user values(1,'tom',18)")
print('添加语句受影响的行数：',insert)

#另一种插入数据的方式，通过字符串传入值
sql="insert into user values(%s,%s,%s)"
cur.execute(sql,(3,'kongsh',20))

cur.close()
conn.commit()
conn.close()
print('sql执行成功')

批量插入多条数据

import pymysql
#打开数据库连接，不指定数据库
conn=pymysql.connect('localhost','root','123456')
conn.select_db('pythondb')
#获取游标
cur=conn.cursor()

#另一种插入数据的方式，通过字符串传入值
sql="insert into user values(%s,%s,%s)"
insert=cur.executemany(sql,[(4,'wen',20),(5,'tom',10),(6,'test',30)])
print ('批量插入返回受影响的行数：',insert)
cur.close()
conn.commit()
conn.close()
print('sql执行成功')

查询数据

import pymysql
#打开数据库连接
conn=pymysql.connect('localhost','root','123456')
conn.select_db('pythondb')
#获取游标
cur=conn.cursor()

cur.execute("select * from user;")
while 1:
　　res=cur.fetchone()
　　if res is None:
　　#表示已经取完结果集
　　　　break
　　print (res)
cur.close()
conn.commit()
conn.close()
print('sql执行成功')

fetchmany

import pymysql
#打开数据库连接
conn=pymysql.connect(‘localhost’,‘root’,‘123456’)
conn.select_db(‘pythondb’)
#获取游标
cur=conn.cursor()

cur.execute(“select * from user”)
#取3条数据
resTuple=cur.fetchmany(3)
print(type(resTuple))
for res in resTuple:
　　print (res)

cur.close()
conn.commit()
conn.close()
print(‘sql执行成功’)

fetchall

import pymysql
#打开数据库连接
conn=pymysql.connect(‘localhost’,‘root’,‘123456’)
conn.select_db(‘pythondb’)
#获取游标
cur=conn.cursor()

cur.execute(“select * from user”)
#取所有数据
resTuple=cur.fetchall()
print(type(resTuple))
print (‘共%d条数据’%len(resTuple))

cur.close()
conn.commit()
conn.close()
print(‘sql执行成功’)

更新数据

import pymysql
#打开数据库连接
conn=pymysql.connect('localhost','root','123456')
conn.select_db('pythondb')
#获取游标
cur=conn.cursor()

#更新一条数据
update=cur.execute("update user set age=100 where name='kongsh'")
print('修改后受影响的行数为：',update)
#查询一条数据
cur.execute(select * from user where name="kongsh";')
print(cur.fetchone())
cur.close()
conn.commit()
conn.close()
print('sql执行成功')

更新多条数据

import pymysql
#打开数据库连接
conn=pymysql.connect('localhost','root','123456')
conn.select_db('pythondb')
#获取游标
cur=conn.cursor()

#更新前查询所有数据
cur.execute("select * from user where name in ('kongsh','wen');")
print('更新前的数据为：')
for res in cur.fetchall():
　　print (res)

print ('*'*40) 
#更新2条数据
sql="update user set age=%s where name=%s"
update=cur.executemany(sql,[(15,'kongsh'),(18,'wen')])

#更新2条数据后查询所有数据
cur.execute("select * from user where name in ('kongsh','wen');")
print('更新后的数据为：')
for res in cur.fetchall():
　　print (res)


cur.close()
conn.commit()
conn.close()
print('sql执行成功')

删除数据

import pymysql
#打开数据库连接
conn=pymysql.connect('localhost','root','123456')
conn.select_db('pythondb')
#获取游标
cur=conn.cursor()

#删除前查询所有数据
cur.execute("select * from user;")
print('删除前的数据为：')
for res in cur.fetchall():
　　print (res)

print ('*'*40) 
#删除1条数据
cur.execute("delete from user where id=1")

#删除后查询所有数据
cur.execute("select * from user;")
print('删除后的数据为：')
for res in cur.fetchall():
　　print (res)
cur.close()
conn.commit()
conn.close()
print('sql执行成功')

删除多条数据

import pymysql
#打开数据库连接
conn=pymysql.connect('localhost','root','123456')
conn.select_db('pythondb')
#获取游标
cur=conn.cursor()

#删除前查询所有数据
cur.execute("select * from user;")
print('删除前的数据为：')
for res in cur.fetchall():
　　print (res)

print ('*'*40) 
#删除2条数据
sql="delete from user where id=%s"
cur.executemany(sql,[(3),(4)])

#删除后查询所有数据
cur.execute("select * from user;")
print('删除后的数据为：')
for res in cur.fetchall():
　　print(res)
cur.close()
conn.commit()
conn.close()
print('sql执行成功')

事务回滚

import pymysql
#打开数据库连接
conn=pymysql.connect('localhost','root','123456')
conn.select_db('pythondb')
#获取游标
cur=conn.cursor()

#修改前查询所有数据
cur.execute("select * from user;")
print('修改前的数据为：')
for res in cur.fetchall():
　　print (res)

print ('*'*40) 
#更新表中第1条数据
cur.execute("update user set name='xiaoxiaoxiaoxiaoren' where id=5")

#修改后查询所有数据
cur.execute("select * from user;")
print('修改后的数据为：')
for res in cur.fetchall():
　　print(res)
print ('*'*40)
#回滚事务
conn.rollback()
cur.execute("select * from user;")
print('回滚事务后的数据为：')
for res in cur.fetchall():
　　print (res)

cur.close()
conn.commit()
conn.close()
print('sql执行成功')

插入100条数据到数据库

import pymysql
import string,random
#打开数据库连接
conn=pymysql.connect('localhost','root','123456')
conn.select_db('testdb')
#获取游标
cur=conn.cursor()

#创建user表
cur.execute('drop table if exists user')
sql="""CREATE TABLE IF NOT EXISTS `user` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`name` varchar(255) NOT NULL,
`age` int(11) NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 AUTO_INCREMENT=0"""

cur.execute(sql)

#修改前查询所有数据
cur.execute("select * from user;")
print('修改前的数据为：')
for res in cur.fetchall():
　　print(res)

print ('*'*40) 
#循环插入数据
words=list(string.ascii_letters)
sql="insert into user values(%s,%s,%s)"
for i in range(100):
　　random.shuffle(words)#打乱顺序
　　cur.execute(sql,(i+1,"".join(words[:5]),random.randint(0,80)))

#插入100条后查询所有数据
cur.execute("select * from user;")
print('修改后的数据为：')
for res in cur.fetchall():
　　print (res)
print ('*'*40)

cur.close()
conn.commit()
conn.close()
print('sql执行成功')

一次插入多条

import pymysql
import string,random
#打开数据库连接
conn=pymysql.connect('localhost','root','123456')
conn.select_db('testdb')
#获取游标
cur=conn.cursor()

#创建user表
cur.execute('drop table if exists user')
sql="""CREATE TABLE IF NOT EXISTS `user` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`name` varchar(255) NOT NULL,
`age` int(11) NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 AUTO_INCREMENT=0"""

cur.execute(sql)

#修改前查询所有数据
cur.execute("select * from user;")
print('修改前的数据为：')
for res in cur.fetchall():
　　print (res)

print ('*'*40) 
#循环插入数据
words=list(string.ascii_letters)
sql="insert into user values(%s,%s,%s)"
random.shuffle(words)#打乱顺序
cur.executemany(sql,[(i+1,"".join(words[:5]),random.randint(0,80)) for i in range(100) ])

#插入100条后查询所有数据
cur.execute("select * from user;")
print('修改后的数据为：')
for res in cur.fetchall():
　　print (res)
print ('*'*40)

cur.close()
conn.commit()
conn.close()
print('sql执行成功')

内容总结

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

内容备注

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

内容手机端

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

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

来源：【匿名】

【上一篇】python MySQL库的操作_DB库【下一篇】浅谈PHP运行Python脚本的方法

更多 ►

【python3 使用pymysql】教程文章相关的互联网学习教程文章

【转】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 3.6.5 导入pymysql模块出错：No module named 'pymysql'【图】

检查一下项目设置中的解释器。查看是否添加PyMySQL模块，如果没有请添加PyMySQL模块'' ref='nofollow'>Python 3.6.5 导入pymysql模块出错：No module named 'pymysql'原文：https://www.cnblogs.com/zhan1995/p/8920369.html

python运维开发(十二)----rabbitMQ、pymysql、SQLAchemy

内容目录：rabbitMQ python操作mysql，pymysql模块 Python ORM框架，SQLAchemy模块 Paramiko 其他with上下文切换rabbitMQ RabbitMQ是一个在AMQP基础上完整的，可复用的企业消息系统。他遵循Mozilla Public License开源协议。 MQ全称为Message Queue, 消息队列（MQ）是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息（针对应用程序的数据）来通信，而无需专用连接来链接它们。消息传递指的是程序之间通过在消息...

mac多版本python安装 pymysql【代码】

如果没有报错，则表示安装成功。但是，这个是在2.7版本下安装成功的。跑到eclipse里面去敲代码，还提示错误。只好到3.4版本下再下载一个。找到3.4到安装路径，我的是 /Library/Frameworks/Python.framework/Versions/3.4/bin 这个目录下有个pip3.4，运行以下命令，安装pymysql ./pip3.4 install PyMySQL 安装成功之后，在python3.4版本下就可以应用pymysql了。转载于http://www.cnblogs.com/wardensky/p/4782944.htmlmac多版本py...

python操作pymysql【代码】

#_author:来童星#date:2019/12/19import pymysql#1.打开数据库连接db=pymysql.connect(‘localhost‘,‘root‘,‘root‘,‘test‘)#2.使用cursor()方法创建一个游标对象cursor=db.cursor()#3.使用execute()方法执行SQL查询cursor.execute(‘select verson()‘)#4.使用fetchone方法获取单条数据data=cursor.fetchone()print(‘database version is : %s‘%data)#5.关闭数据库连接db.close()python操作pymysql标签：一个执行 my...

3-Ubuntu下python3安装pymysql模块(1)【图】

3-Ubuntu下python3安装pymysql模块(1)标签：style python3安装 ubunt python ima inf 模块 mic install 本文系统来源：https://www.cnblogs.com/summer1019/p/11044356.html

Python学习第113天（pymysql模块）【代码】【图】

=input(‘用户名: ‘).strip() pwd=input(‘密码: ‘).strip()#链接 conn=pymysql.connect(host=‘localhost‘,user=‘root‘,password=‘123‘,database=‘egon‘,charset=‘utf8‘) #游标 cursor=conn.cursor() #执行#8;完毕返回的结果集默认以元组显示 #cursor=conn.cursor(cursor=pymysql.cursors.DictCursor)#执行sql语句 sql=‘select * from userinfo where name="%s" and password="%s"‘ %(user,pwd) #注意%s需要加引号 p...

首页 / PYTHON / python3 使用pymysql

python3 使用pymysql

内容导读

内容图文

内容总结

内容备注

内容手机端

【python3 使用pymysql】教程文章相关的互联网学习教程文章

PYMYSQL - 相关标签

PYTHON3 - 相关标签

PYTHON - 技术教程分类

PYTHON - 最新教程

PYTHON - 最热教程