python学习笔记十（连接并操控数据库）_python中如何使用connect

数据库编程接口

连接对象

数据库连接对象(Connection Object)主要提供获取数据库游标对象和提交、回滚事务的方法，以及关闭数据库连接。
connect() 函数常用的参数及说明如下表

connect = pymysql.connect(host="localhost",
                          user="user",
                          password="root",
                          db="ivps",
                          charset="utf-8",
                          cursorclass=pymysql.cursors.DictCursor)
1
2
3
4
5
6

连接对象方法如下表

游标对象的方法如下表

SQLite数据库

与许多其他数据库管理系统不同，SQLite 不是一一个客户端/服务器结构的数据库引擎，而是一种嵌入式数据库，它的数据库就是一个文件。SQLite 将整个数据库，包括定义，表、索引以及数据本身，作为一个单独的、可跨平台使用的文件存储在主机中。由于SQLite本身是C写的，而且体积很小，所以，经常被集成到各种应用程序中。Python 就内置了sQLite3, 所以在Python中使用SQLite，不需要安装任何模块，直接使用。
1

import sqlite3  #导入模块
connect = sqlite3.connect("ces.db") #连接数据库
cursor = connect.cursor()  #创建游标
cursor.execute("create table user(id int(10) primary key,name varchar(20))") #执行sql语句
cursor.close() #关闭游标
connect.close() #关闭连接
1
2
3
4
5
6

添加数据

由于是新增数据，需要使用commit()方法提交事务。因为对于增加、修改和删除操作，
使用commit)方法提交事务后，如果相应操作失败，可以使用rollback()方法回滚到操作之前的状态

import sqlite3  #导入模块
connect = sqlite3.connect("ces.db")
cursor = connect.cursor()
cursor.execute("insert into user(id,name) values(1,'我是一号')")
cursor.execute("insert into user(id,name) values(2,'我是二号')")
cursor.execute("insert into user(id,name) values(3,'我是三号')")
cursor.close()
connect.commit() #提交事务
connect.close()
1
2
3
4
5
6
7
8
9

查看用户信息

获取查询数据方法如下表

import sqlite3  #导入模块
connect = sqlite3.connect("ces.db")
cursor = connect.cursor()
cursor.execute("select * from user")
result1 = cursor.fetchone()
result2 = cursor.fetchmany(2)
result3 = cursor.fetchall()
print(result1)  #得到 (1, '我是一号')
print(result2)  #得到 [(1, '我是一号'), (2, '我是二号')]
print(result3)  #得到 [(1, '我是一号'), (2, '我是二号'), (3, '我是三号')]
cursor.close()
connect.close()
1
2
3
4
5
6
7
8
9
10
11
12

如果已经打印了result1，那么再次打印的result2中不包含result1的内容

修改cursor.execute("select * from user")为cursor.execute("select * from user where id > ?",(1,))
得出
[(2, '我是二号'), (3, '我是三号')]
即不打印第一行数据
1
2
3
4

修改数据

语法：update 表名 set 字段名 = 字段值 where 条件

import sqlite3  #导入模块
connect = sqlite3.connect("ces.db")
cursor = connect.cursor()
cursor.execute("update user set name=? where id=?",("我被修改了",1))
cursor.execute("select * from user")
result = cursor.fetchall()
print(result)
connect.commit()
cursor.close()
connect.close()
[(1, '我被修改了'), (2, '我是二号'), (3, '我是三号')]
1
2
3
4
5
6
7
8
9
10
11

删除数据

语法：delete from 表明 where 查询条件

import sqlite3  #导入模块
connect = sqlite3.connect("ces.db")
cursor = connect.cursor()
cursor.execute("delete from user where id=?",(1,))
cursor.execute("select * from user")
result = cursor.fetchall()
print(result)
connect.commit()
cursor.close()
connect.close()
[(2, '我是二号'), (3, '我是三号')]
1
2
3
4
5
6
7
8
9
10
11

Mysql

安装pymysql

pip install pymysql
1

连接数据库

import pymysql
db = pymysql.connect("localhost","root","root","ces") #分别代表主机地址、用户名、密码、数据库名称
#连接数据库一般以下面的方法为准，不会出错
db = pymysql.connect(host="127.0.0.1",
                       port=3306,
                       user="root",
                       passwd="root",
                       db="mrsoft",
                       charset="utf8")
cursor = db.cursor() #创建游标
cursor.execute("select version()") #通过游标查询数据库版本
result = cursor.fetchall() #获取全部查询结果
print(result) #打印查询结果
cursor.close() #关闭游标
db.close() #关闭连接
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

创建表格

import pymysql
dbmysql = pymysql.connect("localhost","root","root","ces") #分别代表主机地址、用户名、密码、数据库名称
cursor = dbmysql.cursor() #创建游标
cursor.execute("DROP TABLE IF EXISTS book") #如果存在book表则删除
sql = """
create table book(
xno int(4) primary key,
xname varchar(20) not null,
loc varchar(20),
index collage_index(xname)
)engine=innodb default charset=utf8; 
"""
cursor.execute(sql)
cursor.execute("SHOW DATABASES;") #查询数据库所有表名称
result = cursor.fetchall() #获取全部查询结果
dbmysql.commit()
print(result) #打印查询结果
cursor.close() #关闭游标
dbmysql.close() #关闭连接
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

插入MySQL表的数据

import pymysql
db = pymysql.connect("localhost","root","root","ces")
cursor = db.cursor()
data = [(1,'lihua','dhdt'),
        (2,'daming','hd'),
        (3,'xiaohong','rrr'),
        ]
try:
    cursor.executemany("insert into book(xno,xname,loc) VALUES (%s,%s,%s)",data)
    #cursor.execute("INSERT INTO book(xno,xname,loc) VALUES(1,'lihua','dhdt'),(2,'daming','hd'),(3,'xiaohong','rrr')")
    db.commit()
except:
    print("发送错误，回滚")
    db.rollback()
db.close()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15