Python操作Mysql模块的安装
Windows:
https://dev.mysql.com/downloads/connector/python/2.1.html
SQL基本使用
1、数据库操作
show databases;
use database_name;
1、2创建数据表
create table student(
id int(4) not null auto_increment primary key,
name varchar(32) not null,
sex char(4) not null,
age tinyint unsigned not null);
Python-connector操作数据库
创建数据表之后，我们通过Python来操作数据库，执行代码后，通过sql语句查看数据库的变动。
import mysql.connector
config = {
'host': '127.0.0.1', # 连接的IP地址
'user': 'root',
'password': '123456',
'port': 3306,
'database': 'data',
'charset': 'utf8', # 编码格式,防止查出来的数据中文乱码
}
conn = mysql.connector.Connect(**config)
cor = conn.cursor()
# 新增
cor.execute("insert into student values(%s,%s,%s,%s)",(2,'胖多','女',36))
# 修改
cor.execute("update student SET age=%s WHERE age=36",(18,))
# 查询
cor.execute("select name,age from student WHERE ID=1;")
# 删除
cor.execute("delete from student WHERE ID=1;")
conn.commit() # 提交
# 切记一定要关闭游标和连接
cor.close()
conn.close()
Python操作数据库数据
# _author_='shaojie'
# -*- coding:utf-8 -*-
import mysql.connector
config = {
'host': '127.0.0.1', # 连接的IP地址
'user': 'root',
'password': '123456',
'port': 3306,
'database': 'data',
'charset': 'utf8', # 编码格式,防止查出来的数据中文乱码
}
conn = mysql.connector.Connect(**config)
cor = conn.cursor()
# 查询数据是
cor.execute("select * from student;")
conn.commit() # 提交
cor.fetchone() # 返回一条数据,元祖形式
cor.fetchall() # 返回所有数据,元祖嵌套元祖
# 关闭游标和连接
cor.close()
最终优化版
import mysql.connector
config = {
'host': '127.0.0.1', # 连接的IP地址
'user': 'root',
'password': '123456',
'port': 3306,
'database': 'data',
'charset': 'utf8', # 编码格式,防止查出来的数据中文乱码
}
conn = mysql.connector.Connect(**config)
cor = conn.cursor()
# 查询数据是
try:
cor.execute("select * from student;")
conn.commit() # 提交
cor.fetchone() # 返回一条数据,元祖形式
cor.fetchall() # 返回所有数据,元祖嵌套元祖
except ConnectionError as e:
print(e)
except Exception as msg:
print(msg)
finally:
# 关闭游标和连接
cor.close()
conn.close()
