热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

python通过什么对象连接数据库步骤_Python连接MySQL数据库方法介绍(超详细!手把手项目案例操作)...

本文涉及到的开发环境:操作系统Windows10数据库MySQL8.0Python3.7.2pip19.0.3两种方法进行数据库的连接分别是PyMySQL和mysql

本文涉及到的开发环境:操作系统 Windows 10

数据库 MySQL 8.0

Python 3.7.2

pip 19.0.3

两种方法进行数据库的连接分别是PyMySQL和mysql.connector

步骤:连接数据库

生成游标对象

执行SQL语句

关闭游标

关闭连接

PyMySQL

PyMySQL : 是封装了MySQL驱动的Python驱动,一个能使Python连接到MySQL的库

环境要求:Python version >= 3.4

PyMySQL安装

安装

Win键+X键再按I键,调出Windows PowerShell窗口,输入

pip install PyMySQL

回车

运行结果如下则安装成功

pip version ===19.0.3

查看版本

查看PyMySQL的版本,输入

pip show PyMySQL

回车

利用PyMySQL连接数据库

首先我们的MySQL数据库已安装,且已建好名为test的数据库,其中有名为student的表

import pymysql

#连接数据库

conn=pymysql.connect(host = '127.0.0.1' # 连接名称,默认127.0.0.1

,user = 'root' # 用户名

,passwd='password' # 密码

,port= 3306 # 端口,默认为3306

,db='test' # 数据库名称

,charset='utf8' # 字符编码

)

cur = conn.cursor() # 生成游标对象

sql='select * from `student` ' # SQL语句

cur.execute(sql) # 执行SQL语句

data = cur.fetchall() # 通过fetchall方法获得数据

for i in data[:2]: # 打印输出前2条数据

print (i)

cur.close() # 关闭游标

conn.close() # 关闭连接

上述代码中,实现了通过Python连接MySQL查询所有的数据,并输出前2条数据的功能。执行结果如下:

('a', '赵大', '16')

('b', '钱二', '16')

mysql.connector

mysql-connector-python:是MySQL官方的纯Python驱动;

mysql.connector安装

安装

pip install mysql

查看版本

pip show mysql

利用 mysql.connector连接数据库

首先我们的MySQL数据库已安装,且已建好名为test的数据库,其中有名为student的表

import mysql.connector

conn=mysql.connector.connect(host = '127.0.0.1' # 连接名称,默认127.0.0.1

,user = 'root' # 用户名

,passwd='password' # 密码

,port= 3306 # 端口,默认为3306

,db='test' # 数据库名称

,charset='utf8' # 字符编码

)

cur = conn.cursor() # 生成游标对象

sql='select * from `student` ' # SQL语句

cur.execute(sql) # 执行SQL语句

data = cur.fetchall() # 通过fetchall方法获得数据

for i in data[:2]: # 打印输出前2条数据

print (i)

cur.close() # 关闭游标

conn.close() # 关闭连接

上述代码中,实现了通过Python连接MySQL查询所有的数据,并输出前2条数据的功能。执行结果如下:

('a', '赵大', '16')

('b', '钱二', '16')

Python对MySql数据库实现增删改查

接下来我们以用pymysql包为例,介绍一下如何用Python对数据库中的数据进行增删改查 。

import pymysql

#连接数据库

conn=pymysql.connect(host = '127.0.0.1' # 连接名称,默认127.0.0.1

,user = 'root' # 用户名

,passwd='password' # 密码

,port= 3306 # 端口,默认为3306

,db='test' # 数据库名称

,charset='utf8' # 字符编码

)

cur = conn.cursor() # 生成游标对象

#=============插入语句===============================

sql= 'INSERT INTO student VALUES ('p','魏六','17')'

#===================================================

try:

cur.execute(sql1) # 执行插入的sql语句

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

except:

coon.rollback()# 如果发生错误则回滚

conn.close() # 关闭数据库连接

然后我们再运行查询语句

import mysql.connector

conn=mysql.connector.connect(host = '127.0.0.1' # 连接名称,默认127.0.0.1

,user = 'root' # 用户名

,passwd='password' # 密码

,port= 3306 # 端口,默认为3306

,db='test' # 数据库名称

,charset='utf8' # 字符编码

)

cur = conn.cursor() # 生成游标对象

sql='select * from `student` ' # SQL语句

cur.execute(sql) # 执行SQL语句

data = cur.fetchall() # 通过fetchall方法获得数据

for i in data[:]: # 打印输出所有数据

print (i)

cur.close() # 关闭游标

conn.close() # 关闭连接

执行结果就是

('b', '钱二', '16')

('c', '张三', '17')

('d', '李四', '17')

('e', '王五', '16')

('a', '赵大', '16')

('p', '魏六', '17')

import pymysql

#连接数据库

conn=pymysql.connect(host = '127.0.0.1' # 连接名称,默认127.0.0.1

,user = 'root' # 用户名

,passwd='password' # 密码

,port= 3306 # 端口,默认为3306

,db='test' # 数据库名称

,charset='utf8' # 字符编码

)

cur = conn.cursor() # 生成游标对象

#=============删除语句===============================

sql = 'DELETE FROM student WHERE `学号` = 'a'

#===================================================

try:

cur.execute(sql) # 执行插入的sql语句

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

except:

coon.rollback()# 如果发生错误则回滚

conn.close() # 关闭数据库连接

import pymysql

#连接数据库

conn=pymysql.connect(host = '127.0.0.1' # 连接名称,默认127.0.0.1

,user = 'root' # 用户名

,passwd='password' # 密码

,port= 3306 # 端口,默认为3306

,db='test' # 数据库名称

,charset='utf8' # 字符编码

)

cur = conn.cursor() # 生成游标对象

#=============删除语句===============================

sql ='UPDATE student SET `学员姓名` = '欧阳' WHERE `学号` = 'b' '

#===================================================

try:

cur.execute(sql) # 执行插入的sql语句

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

except:

coon.rollback()# 如果发生错误则回滚

conn.close() # 关闭数据库连接

import pymysql

#连接数据库

conn=pymysql.connect(host = '127.0.0.1' # 连接名称,默认127.0.0.1

,user = 'root' # 用户名

,passwd='password' # 密码

,port= 3306 # 端口,默认为3306

,db='test' # 数据库名称

,charset='utf8' # 字符编码

)

cur = conn.cursor() # 生成游标对象

#=============删除语句===============================

sql='select * from `student` ' # SQL语句

#====================================================

try:

cur.execute(sql) # 执行插入的sql语句

data = cur.fetchall()

for i in data[:]:

print (i)

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

except:

coon.rollback()# 如果发生错误则回滚

conn.close() # 关闭数据库连接

小型案例

import pymysql

config = {

'host': '127.0.0.1',

'port': 3306,

'user': 'root',

'passwd': 'password',

'charset':'utf8',

}

conn = pymysql.connect(**config)

cursor = conn.cursor()

try:

# 创建数据库

DB_NAME = 'test_3'

cursor.execute('DROP DATABASE IF EXISTS %s' %DB_NAME)

cursor.execute('CREATE DATABASE IF NOT EXISTS %s' %DB_NAME)

conn.select_db(DB_NAME)

#创建表

TABLE_NAME = 'bankData'

cursor.execute('CREATE TABLE %s(id int primary key,money int(30))' %TABLE_NAME)

# 批量插入纪录

values = []

for i in range(20):

values.append((int(i),int(156*i)))

cursor.executemany('INSERT INTO bankData values(%s,%s)',values)

conn.commit()

# 查询数据条目

count = cursor.execute('SELECT * FROM %s' %TABLE_NAME)

print ('total records:{}'.format(cursor.rowcount))

# 获取表名信息

desc = cursor.description

print ('%s %3s' % (desc[0][0], desc[1][0]))

cursor.scroll(10,mode='absolute')

results = cursor.fetchall()

for result in results:

print (result)

except:

import traceback

traceback.print_exc()

# 发生错误时会滚

conn.rollback()

finally:

# 关闭游标连接

cursor.close()

# 关闭数据库连接

conn.close()

综合案例

FIFA球员信息系统

from pymysql import *

class Mysqlpython:

def __init__(self, database='test', host='127.0.0.1', user='root',

password='password', port=3306, charset='utf8'):

self.host = host

self.user = user

self.password = password

self.port = port

self.database = database

self.charset = charset

# 数据库连接方法:

def open(self):

self.db = connect(host=self.host, user=self.user,

password=self.password, port=self.port,

database=self.database,

charset=self.charset)

# 游标对象

self.cur = self.db.cursor()

# 数据库关闭方法:

def close(self):

self.cur.close()

self.db.close()

# 数据库执行操作方法:

def Operation(self, sql):

try:

self.open()

self.cur.execute(sql)

self.db.commit()

print('ok')

except Exception as e:

self.db.rollback()

print('Failed', e)

self.close()

# 数据库查询所有操作方法:

def Search(self, sql):

try:

self.open()

self.cur.execute(sql)

result = self.cur.fetchall()

return result

except Exception as e:

print('Failed', e)

self.close()

def Insert():#如何从外面将数据录入到sql语句中

ID = int(input('请输入球员编号:'))

people_name = input('请输入球员名字:')

PAC = int(input('请输入速度评分:'))

DRI = int(input('请输入盘带评分:'))

SHO = int(input('请输入射门评分:'))

DEF = int(input('请输入防守评分:'))

PAS = int(input('请输入传球评分:'))

PHY = int(input('请输入身体评分:'))

score =(PAC+DRI+SHO+DEF+PAS+PHY)/6

sql_insert = 'insert into FIFA(ID, people_name, PAC,DRI,SHO,DEF, PAS, PHY, score) values(%d,'%s',%d,%d,%d,%d,%d,%d,%d)'%(ID, people_name, PAC,DRI,SHO,DEF, PAS, PHY, score)

print(people_name)

return sql_insert

def Project():

print('球员的能力评分有:')

list=['速度','盘带','射门','防守','传球','身体','综合']

print(list)

def Exit():

print('欢迎下次使用!!!')

exit()

def Search_choice(num):

date = Mysqlpython()

date.open()

if num=='2':

# 1.增加操作

sql_insert = Insert()

date.Operation(sql_insert)

print('添加成功!')

Start()

elif num=='1':

# 2.查找数据,其中order by 是为了按什么顺序输出,asc 是升序输出,desc降序输出

input_date=input('请选择您想要以什么格式输出:默认升序排列1.球员编号,2.速度,3.盘带,4.射门, 5.防守, 6.传球, 7.身体 , 8.综合 ')

if input_date=='1':

sql_search = 'select * from FIFA order by ID asc'

elif input_date=='2':

sql_search = 'select * from FIFA order by PAC asc'

elif input_date=='3':

sql_search = 'select * from FIFA order by DRI asc'

elif input_date=='4':

sql_search = 'select * from FIFA order by SHO asc'

elif input_date=='5':

sql_search = 'select * from FIFA order by DEF asc'

elif input_date=='6':

sql_search = 'select * from FIFA order by PAS asc'

elif input_date=='7':

sql_search = 'select * from FIFA order by PHY asc'

elif input_date=='8':

sql_search = 'select * from FIFA order by PHY score'

else:

print('请重新输入!')

result = date.Search(sql_search)

print(' 编号 姓名 速度 盘带 射门 防守 传球 身体 综合 ')

for str in result:

print(str)

Start()

elif num=='3':

Project()

Start()

elif num=='4':

del_num=input('请输入您要删除球员的编号:')

sql_delete='delete from FIFA where id=%s'%del_num

date.Operation(sql_delete)

print('删除成功!')

Start()

elif num=='5':

Exit()

else:

print('输入有误,请重新输入!')

def Start():

print('********************************************************')

print('* 欢迎来到FIFA球员信息系统 *')

print('*1.查看球员信息 2.球员信息录入 *')

print('*3.球员能力 4.删除球员信息 *')

print('*5.退出系统 *')

print('********************************************************')

choice = input('请输入您的选择:')

Search_choice(choice)

if __name__=='__main__':

Start()

银行转账系统

先建立数据库test_3和表bankdata

import pymysql

config = {

'host': '127.0.0.1',

'port': 3306,

'user': 'root',

'passwd': 'password',

'charset':'utf8',

}

conn = pymysql.connect(**config)

cursor = conn.cursor()

try:

# 创建数据库

DB_NAME = 'test_3'

cursor.execute('DROP DATABASE IF EXISTS %s' %DB_NAME)

cursor.execute('CREATE DATABASE IF NOT EXISTS %s' %DB_NAME)

conn.select_db(DB_NAME)

#创建表

TABLE_NAME = 'bankData'

cursor.execute('CREATE TABLE %s(id int primary key,money int(30))' %TABLE_NAME)

# 批量插入纪录

values = []

for i in range(20):

values.append((int(i),int(156*i)))

cursor.executemany('INSERT INTO bankData values(%s,%s)',values)

conn.commit()

# 查询数据条目

count = cursor.execute('SELECT * FROM %s' %TABLE_NAME)

print ('total records:{}'.format(cursor.rowcount))

# 获取表名信息

desc = cursor.description

print ('%s %3s' % (desc[0][0], desc[1][0]))

cursor.scroll(10,mode='absolute')

results = cursor.fetchall()

for result in results:

print (result)

except:

import traceback

traceback.print_exc()

# 发生错误时会滚

conn.rollback()

finally:

# 关闭游标连接

cursor.close()

# 关闭数据库连接

conn.close()

构建系统

import pymysql

class TransferMoney(object):

# 构造方法

def __init__(self, conn):

self.conn = conn

self.cur = conn.cursor()

def transfer(self, source_id, target_id, money):

if not self.check_account_avaialbe(source_id):

raise Exception('账户不存在')

if not self.check_account_avaialbe(target_id):

raise Exception('账户不存在')

if self.has_enough_money(source_id, money):

try:

self.reduce_money(source_id, money)

self.add_money(target_id, money)

except Exception as e:

print('转账失败:', e)

self.conn.rollback()

else:

self.conn.commit()

print('%s给%s转账%s金额成功' % (source_id, target_id, money))

def check_account_avaialbe(self, acc_id):

'''判断帐号是否存在, 传递的参数是银行卡号的id'''

select_sqli = 'select * from bankData where id=%d;' % (acc_id)

print('execute sql:', select_sqli)

res_count = self.cur.execute(select_sqli)

if res_count == 1:

return True

else:

# raise Exception('账户%s不存在' %(acc_id))

return False

def has_enough_money(self, acc_id, money):

'''判断acc_id账户上金额> money'''

# 查找acc_id存储金额?

select_sqli = 'select money from bankData where id=%d;' % (acc_id)

print('execute sql:', select_sqli)

self.cur.execute(select_sqli) # ((1, 500), )

# 获取查询到的金额钱数;

acc_money = self.cur.fetchone()[0]

# 判断

if acc_money >= money:

return True

else:

return False

def add_money(self, acc_id, money):

update_sqli = 'update bankData set money=money+%d where id=%d' % (money, acc_id)

print('add money:', update_sqli)

self.cur.execute(update_sqli)

def reduce_money(self, acc_id, money):

update_sqli = 'update bankData set money=money-%d where id=%d' % (money, acc_id)

print('reduce money:', update_sqli)

self.cur.execute(update_sqli)

# 析构方法

def __del__(self):

self.cur.close()

self.conn.close()

if __name__ == '__main__':

# 1. 连接数据库,

conn = pymysql.connect(host = '127.0.0.1' # 连接名称,默认127.0.0.1

,user = 'root' # 用户名

,passwd='password' # 密码

,port= 3306 # 端口,默认为3306

,db='test_3' # 数据库名称

,charset='utf8'

,autocommit=True, # 如果插入数据,自动提交给数据库

)

trans = TransferMoney(conn)

trans.transfer(15, 12, 200)



推荐阅读
  • MyBatis多表查询与动态SQL使用
    本文介绍了MyBatis多表查询与动态SQL的使用方法,包括一对一查询和一对多查询。同时还介绍了动态SQL的使用,包括if标签、trim标签、where标签、set标签和foreach标签的用法。文章还提供了相关的配置信息和示例代码。 ... [详细]
  • 安装mysqlclient失败解决办法
    本文介绍了在MAC系统中,使用django使用mysql数据库报错的解决办法。通过源码安装mysqlclient或将mysql_config添加到系统环境变量中,可以解决安装mysqlclient失败的问题。同时,还介绍了查看mysql安装路径和使配置文件生效的方法。 ... [详细]
  • Spring特性实现接口多类的动态调用详解
    本文详细介绍了如何使用Spring特性实现接口多类的动态调用。通过对Spring IoC容器的基础类BeanFactory和ApplicationContext的介绍,以及getBeansOfType方法的应用,解决了在实际工作中遇到的接口及多个实现类的问题。同时,文章还提到了SPI使用的不便之处,并介绍了借助ApplicationContext实现需求的方法。阅读本文,你将了解到Spring特性的实现原理和实际应用方式。 ... [详细]
  • Java String与StringBuffer的区别及其应用场景
    本文主要介绍了Java中String和StringBuffer的区别,String是不可变的,而StringBuffer是可变的。StringBuffer在进行字符串处理时不生成新的对象,内存使用上要优于String类。因此,在需要频繁对字符串进行修改的情况下,使用StringBuffer更加适合。同时,文章还介绍了String和StringBuffer的应用场景。 ... [详细]
  • 本文介绍了三种方法来实现在Win7系统中显示桌面的快捷方式,包括使用任务栏快速启动栏、运行命令和自己创建快捷方式的方法。具体操作步骤详细说明,并提供了保存图标的路径,方便以后使用。 ... [详细]
  • ubuntu用sqoop将数据从hive导入mysql时,命令: ... [详细]
  • 本文介绍了Python对Excel文件的读取方法,包括模块的安装和使用。通过安装xlrd、xlwt、xlutils、pyExcelerator等模块,可以实现对Excel文件的读取和处理。具体的读取方法包括打开excel文件、抓取所有sheet的名称、定位到指定的表单等。本文提供了两种定位表单的方式,并给出了相应的代码示例。 ... [详细]
  • 本文介绍了在开发Android新闻App时,搭建本地服务器的步骤。通过使用XAMPP软件,可以一键式搭建起开发环境,包括Apache、MySQL、PHP、PERL。在本地服务器上新建数据库和表,并设置相应的属性。最后,给出了创建new表的SQL语句。这个教程适合初学者参考。 ... [详细]
  • eclipse学习(第三章:ssh中的Hibernate)——11.Hibernate的缓存(2级缓存,get和load)
    本文介绍了eclipse学习中的第三章内容,主要讲解了ssh中的Hibernate的缓存,包括2级缓存和get方法、load方法的区别。文章还涉及了项目实践和相关知识点的讲解。 ... [详细]
  • 本文详细介绍了在ASP.NET中获取插入记录的ID的几种方法,包括使用SCOPE_IDENTITY()和IDENT_CURRENT()函数,以及通过ExecuteReader方法执行SQL语句获取ID的步骤。同时,还提供了使用这些方法的示例代码和注意事项。对于需要获取表中最后一个插入操作所产生的ID或马上使用刚插入的新记录ID的开发者来说,本文提供了一些有用的技巧和建议。 ... [详细]
  • 本文详细介绍了Spring的JdbcTemplate的使用方法,包括执行存储过程、存储函数的call()方法,执行任何SQL语句的execute()方法,单个更新和批量更新的update()和batchUpdate()方法,以及单查和列表查询的query()和queryForXXX()方法。提供了经过测试的API供使用。 ... [详细]
  • 本文讨论了在数据库打开和关闭状态下,重新命名或移动数据文件和日志文件的情况。针对性能和维护原因,需要将数据库文件移动到不同的磁盘上或重新分配到新的磁盘上的情况,以及在操作系统级别移动或重命名数据文件但未在数据库层进行重命名导致报错的情况。通过三个方面进行讨论。 ... [详细]
  • ALTERTABLE通过更改、添加、除去列和约束,或者通过启用或禁用约束和触发器来更改表的定义。语法ALTERTABLEtable{[ALTERCOLUMNcolu ... [详细]
  • 本文介绍了iOS数据库Sqlite的SQL语句分类和常见约束关键字。SQL语句分为DDL、DML和DQL三种类型,其中DDL语句用于定义、删除和修改数据表,关键字包括create、drop和alter。常见约束关键字包括if not exists、if exists、primary key、autoincrement、not null和default。此外,还介绍了常见的数据库数据类型,包括integer、text和real。 ... [详细]
  • 如何在php中将mysql查询结果赋值给变量
    本文介绍了在php中将mysql查询结果赋值给变量的方法,包括从mysql表中查询count(学号)并赋值给一个变量,以及如何将sql中查询单条结果赋值给php页面的一个变量。同时还讨论了php调用mysql查询结果到变量的方法,并提供了示例代码。 ... [详细]
author-avatar
safecaps
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有