mysql登陆命令

mysql -u[用户名] -p[密码]

创建test数据库

create database test;
use test;
create table student(id char(3),name char(5),age int)ENGINE = INNODB charset = utf8;
insert into student values('a','赵大',16);
insert into student values('b','钱二',16);
insert into student values('c','张三',17);
insert into student values('d','李四',17);
insert into student values('e','王五',16);
select * from student;
​

1.使用PyMySQL连接

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

安装PyMySQL

pip install PyMySQL

连接mysql

import pymysql
#连接数据库
conn=pymysql.connect(host = '127.0.0.1' # 连接名称，默认127.0.0.1
,user = 'root' # 用户名
,passwd='123456' # 密码
,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() # 关闭连接

2.使用mysql.connector连接

mysql-connector-python：是MySQL官方的纯Python驱动；

mysql.connector安装

pip install mysql
pip install mysql-connector

利用 mysql.connector连接数据库

import mysql.connector
conn=mysql.connector.connect(host = '127.0.0.1' # 连接名称，默认127.0.0.1
,user = 'root' # 用户名
,passwd='123456' # 密码
,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数据库实现增删改查

#增删改查
import pymysql
#连接数据库
conn=pymysql.connect(host = '127.0.0.1' # 连接名称，默认127.0.0.1
,user = 'root' # 用户名
,passwd='123456' # 密码
,port= 3306 # 端口，默认为3306
,db='test' # 数据库名称
,charset='utf8' # 字符编码
)
cur = conn.cursor() # 生成游标对象
#==============查询语句===============================
sql="select * from student" # SQL语句
#=============插入语句===============================
sql1= "INSERT INTO student VALUES ('p','魏六','17')"
#=============删除语句===============================
sql2 = "DELETE FROM student WHERE id = 'a'"
#===================================================
try:
    cur.execute(sql1) # 执行插入的sql语句
    conn.commit() # 提交到数据库执行
except:
    conn.rollback()# 如果发生错误则回滚
​
​
cur.execute(sql) # 执行SQL语句
data = cur.fetchall() # 通过fetchall方法获得数据
print("这是增加id=p的\n")
for i in data[:]: # 打印输出所有数据
    print (i)
print("===========================================")
# cur.close() # 关闭游标
# cur = conn.cursor() # 生成游标对象
try:
    cur.execute(sql2) # 执行插入的sql语句
    conn.commit() # 提交到数据库执行
except:
    conn.rollback()# 如果发生错误则回滚
​
cur.execute(sql) # 执行SQL语句
data = cur.fetchall() # 通过fetchall方法获得数据
print("这是删除id=a的\n")
for i in data[:]: # 打印输出所有数据
    print (i)
print("===========================================")
cur.close() # 关闭游标
​
conn.close() # 关闭数据库连接