14 . Python3之MysSQL

 # 按照数据模型分类: 
 #       网状数据库
 #       层次数据库
 #       关系型数据库

# 1.数据以表格的形式出现   
# 2.每行为各种记录名称   
# 3.每列为记录名称所对应的数据域   
# 4.许多的行和列组成一张表单   
# 5.若干的表单组成database  

# 数据库: 数据库是一些关联表的集合。.  
# 数据表: 表是数据的矩阵。在一个数据库中的表看起来像一个简单的电子表格。  
# 列: 一列(数据元素) 包含了相同的数据, 例如邮政编码的数据。  
# 行：一行（=元组，或记录）是一组相关的数据，例如一条用户订阅的数据。  
# 冗余：存储两倍数据，冗余可以使系统速度更快。(表的规范化程度越高，表与表之间的关系就越多；查询时可能经常需要在多个表之间进行连接查询；而进行连接操作会降低查询速度。例如，学生的信息存储在student表中，院系信息存储在department表中。通过student表中的dept_id字段与department表建立关联关系。如果要查询一个学生所在系的名称，必须从student表中查找学生所在院系的编号（dept_id），然后根据这个编号去department查找系的名称。如果经常需要进行这个操作时，连接查询会浪费很多的时间。因此可以在student表中增加一个冗余字段dept_name，该字段用来存储学生所在院系的名称。这样就不用每次都进行连接操作了。)

# 主键：主键是唯一的。一个数据表中只能包含一个主键。你可以使用主键来查询数据。  
# 外键： 外键用于关联两个表。  
# 复合键：复合键（组合键）将多个列作为一个索引键，一般用于复合索引。  
# 索引：使用索引可快速访问数据库表中的特定信息。索引是对数据库表中一列或多列的值进行排序的一种结构。类似于书籍的目录。  

# 参照完整性: 参照的完整性要求关系中不允许引用不存在的实体。与实体完整性是关系模型必须满足的完整性约束条件，目的是保证数据的一致性。  

> 非关系型数据库: 通常是以Key-value形式存储的，不支持SQL语句，没有表结构，配置简单，低廉学习成本，能很好作为Mysql中间层:  

​```python
# 1. 键值存储:  Redis<6379>  Memcached<11211>,因为相比其他数据存储没有数据结构，又工作在内存中，所以性能很高.  
# 2. 列式存储:  HBase:  
# 3. 文档存储:  Documentation ,  MongoDB<27017>  

# Hadoop(HDFS):  适用于大文件存储，Apache公司的产品，java程序编写  
# FastDFS(开源软件): 适用于小文件存储(网盘，短视频，images)，对于高并发有很好的支持.  

# Mysql是开源的，所以你不需要支付额外的费用。  
# Mysql支持大型的数据库。可以处理拥有上千万条记录的大型数据库。  
# MySQL使用标准的SQL数据语言形式。  
# Mysql可以允许于多个系统上，并且支持多种语言。这些编程语言包括C、C++、Python、Java、Perl、PHP、Eiffel、Ruby和Tcl等。  
# Mysql对PHP有很好的支持，PHP是目前最流行的Web开发语言。  
# MySQL支持大型数据库，支持5000万条记录的数据仓库，32位系统表文件最大可支持4GB，64位系统支持最大的表文件为8TB。  
# Mysql是可以定制的，采用了GPL协议，你可以修改源码来开发自己的Mysql系统。

# 建议用mysql5.7.23版本,以下采用5.7.23版本  
yum -y install perl libaio expect  
tar xvf mysql-5.7.23-1.el7.x86_64.rpm-bundle.tar  
rpm -ivh mysql-community-server-5.7.23-1.el7.x86_64.rpm   
mysql-community-client-5.7.23-1.el7.x86_64.rpm   
mysql-community-common-5.7.23-1.el7.x86_64.rpm   
mysql-community-libs-5.7.23-1.el7.x86_64.rpm  
systemctl start mysqld  
  
changepass() {  
sed -i '/[mysqld]/ a skip-grant-tables' /etc/my.cnf  
systemctl restart mysqld  
mysql <<EOF  
 update mysql.user set authentication_string='' where user='root' and Host='localhost';  
 flush privileges;  
EOF  
sed -i '/skip-grant/d' /etc/my.cnf  
systemctl restart mysqld  
yum -y install expect ntp  
  
expect <<-EOF  
spawn  mysqladmin -uroot -p password "ZHOUjian.20"  
 expect {  
 "password" { send "r"  }  
}  
 expect eof  
EOF  
systemctl restart mysqld  
}  
changepass  
  
# 授权远程登录  
GRANT ALL PRIVILEGES ON *.* TO 'root'@'%' IDENTIFIED BY 'ZHOUjian.21' WITH GRANT OPTION;   
  
FLUSH PRIVILEGES;   

安装源码Mysql  
#!/usr/bin/env bash  
# Author: ZhouJian  
# Mail: 18621048481@163.com  
# Time: 2019-9-3  
# Describe: CentOS 7 Install Mysql.tar Script        # 此处为编译好的tar包，具体编译维护中  
Deplay(){  
rpm -e mariadb-libs --nodeps  
setenforce 0  
systemctl stop firewalld  
systemctl enable firewalld  
sed -i '/^SELINUX=/ s/enforcing/disabled' /etc/ssh/sshd_config  
sed -i '/^GSSAPIAu/ s/yes/no/' /etc/ssh/sshd_config  
sed -i '/^#UseDNS/ {s/^#//;s/yes/no}' /etc/ssh/sshd_config  
  
id mysql > /dev/null  
if [ $? -eq 0 ];then  
echo "mysql user exist"  
else  
groupadd mysql  
useradd -M -s /sbin/nologin mysql -g mysql  
fi  
if [ ! -d /usr/local/mysqld ];then  
tar xf mysql-5.7.26-bin.tar.xz -C /usr/local/  
chown mysql.mysql /usr/local/mysqld/ -R  
fi  
echo "export PATH=$PATH:/usr/local/mysqld/mysql/bin" >> /etc/profile  
source /etc/profile  
cat > /etc/my.cnf <<EOF  
[mysqld]  
basedir = /usr/local/mysqld/mysql  
datadir = /usr/local/mysqld/data  
tmpdir = /usr/local/mysqld/tmp  
socket = /usr/local/mysqld/tmp/mysql.sock  
pid_file = /usr/local/mysqld/tmp/mysqld.pid  
log_error = /usr/local/mysqld/log/mysql_error.log  
slow_query_log_file = /usr/local/mysqld/log/slow_warn.log  
user = mysql  
port = 3306  
bind-address = 0.0.0.0  
character-set-server = utf8  
default_storage_engine = InnoDB  
EOF  
  
ln -s /usr/local/mysqld/mysql/support-files/mysql.server /usr/bin/mysqldctl  
mysqldctl start  
ln -s /usr/local/mysqld/tmp/mysql.sock /tmp/mysql.sock  
mysqldctl restart  
sed -i '/[mysqld]/ a skip-grant-tables' /etc/my.cnf  
mysqldctl restart  
mysql <<EOF  
update mysql.user set authentication_string='' where user='root' and Host='localhost';  
flush privileges;  
EOF  
sed -i '/skip-grant/d' /etc/my.cnf  
mysqldctl restart  
yum -y install expect ntp  
cat > /etc/ntp.conf << EOF  
restrict default nomodify  
server 127.127.1.0  
fudge 127.127.1.0 stratum 10  
EOF  
systemctl start ntpd ; systemctl enable ntpd  
expect <<-EOF  
spawn mysqladmin -uroot -p password "ZHOUjian.20"  
expect {  
"password" { send "r" }  
}  
expect eof  
EOF  
mysqldctl restart  
}  
Deplay  

# 使用wget下载yum源安装  
wget http://dev.mysql.com/get/mysql57-community-release-el7-8.noarch.rpm  
  
# 安装yum源  
rpm -ivh mysql57-community-release-el7-8.noarch.rpm   
  
# 安装mysql  
yum -y install mysql-server  

# 修改Mysql密码下面有三种办法  
# 1.刚安装好的mysql，可以从/var/log/mysqld.log获取临时密码  
grep  "password"  /var/log/mysqld.log   
 [root@mysql ~]# mysql -uroot -p  
 Enter password:  
 mysql> ALTER USER 'root'@'localhost' IDENTIFIED BY 'ZHOUjian.22';  
  
# 2.mysqladmin -uroot -p password "Baidu.123.com"  
 Enter password:  
  
# 3.实验环境不知道root密码操作方法如下  
sed -i '/[mysqld]/ a skip-grant-tables' /etc/my.cnf  
systemctl restart mysqld  
mysql <<EOF  
 update mysql.user set authentication_string='' where user='root' and Host='localhost';  
 flush privileges;  
EOF  
sed -i '/skip-grant/d' /etc/my.cnf  
systemctl restart mysqld  
mysqladmin -uroot -p password "ZHOUjian.20"  
Enter password:              # 此处回车一下即可  
  
# 4.mariadb修改密码   
use mysql   
UPDATE user SET password=password('ZHOUjian.20') WHERE user='root';   
MariaDB [mysql]> flush privileges;  
  
# 如果嫌登陆Mysql输入密码麻烦，可以使用以下办法，只需要mysql就可以进入数据库  
vim /etc/my.cnf  
[client]  
password=admin  
user=root  
systemctl restart mysqld Or mariadb  

# SQL语言主要用于存取数据，查询数据，更新数据和管理关系数据库系统，由IBM开发，分为四种类型  
# DDL语句        数据库定义语言(Create,Alter,Drop,Declare)   
# 用于定义或改变表的结构，数据类型，表之间的连接和约束等初始化工作上，他们大多在建表时使用.  
  
# DML语句       数据库操作语言（Select,Delete,Update,Insert）    # 用来对数据库里的数据进行操作的语言.  
  
# DCL语句        数据库控制语言(GRANT,REVOKE,COMMIT,ROLLBACK)   
# 用来设置或更改数据库或角色权限的语句，只有sysadmin,dbcreator,db_owner等人员才能执行.  
  
# DQL语句        数据库查询语言（select）  

python -m pip install mysql-connector

import mysql.connector   
    
# 执行以上代码，如果没有报错，表明安装成功   
# 注意: 如果你的 MySQL 是 8.0 版本，密码插件验证方式发生了变化，早期版本为 mysql_native_password，   
# 8.0 版本为 caching_sha2_password，所以需要做些改变：   

# 先修改 my.ini 配置：   
[mysqld]   
default_authentication_plugin=mysql_native_password   
    
# 然后在mysql下执行以下命令来修改密码:   
ALTER USER 'root'@'localhost' IDENTIFIED WITH mysql_native_password BY '新密码';

# 我们可以使用以下代码连接数据库  
import mysql.connector  
  
mydb = mysql.connector.connect(  
 host="121.36.43.123",   # 数据库主机地址  
 user="admin",             # 数据库用户名  
 passwd="ZHOUjian.21"     # 数据库密码  
 # database = "youmen_db"  # 此处可以直接连接指定数据库，如果数据库不存在，会输出错误信息  
)  
print(mydb)  

import mysql.connector  
  
mydb = mysql.connector.connect(  
 host="116.196.83.113",   
 user="root",   
 passwd="ZHOUjian.21"   
)  
  
mycursor = mydb.cursor()  
mycursor.execute("create database youmen_db")  

import mysql.connector  
  
mydb = mysql.connector.connect(  
 host="116.196.83.113",   
 user="root",   
 passwd="ZHOUjian.21"   
)  
  
mycursor = mydb.cursor()  
mycursor.execute("show databases")  
for x in mycursor:  
 print(x)  
  
('information_schema',)  
('mysql',)  
('performance_schema',)  
('sys',)  
('youmen_db',)  

import mysql.connector  
  
mydb = mysql.connector.connect(  
 host="116.196.83.113",   
 user="root",   
 passwd="ZHOUjian.21",  
 database="youmen_db"  
)  
  
mycursor = mydb.cursor()  
mycursor.execute("create table sites(name VARCHAR(255),url VARCHAR(255))")  

#!/usr/bin/env python3  
#-*- coding:utf-8 -*-  
# 2020/2/12 20:24  
  
import mysql.connector  
  
mydb = mysql.connector.connect(  
 host='116.196.83.113',  
 user='root',  
 passwd='ZHOUjian.20',  
 database='youmen_db'  
)  
  
mycursor=mydb.cursor()  
mycursor.execute("create table student(stu_id INT NOT NULL AUTO_INCREMENT,name CHAR(32) NOT NULL ,age INT NOT NULL,register_date DATE,PRIMARY KEY(stu_id))")  

# 给sites表增加主键  
import mysql.connector  
  
mydb = mysql.connector.connect(  
 host="116.196.83.113",   
 user="root",   
 passwd="ZHOUjian.21",  
 database="youmen_db"  
)  
  
mycursor = mydb.cursor()  
  
mycursor.execute("ALTER TABLE sites ADD COLUMN id INT AUTO_INCREMENT PRIMARY KEY")  
# 如果还未创建sites表，可以直接使用以下代码创建  
mycursor.execute("CREATE TABLE sites (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), url VARCHAR(255))")  

# 插入数据使用INSERT INTO语句  
# 向sites表插入一条记录  
import mysql.connector  
  
mydb = mysql.connector.connect(  
 host="116.196.83.113",   
 user="root",   
 passwd="ZHOUjian.21",  
 database="youmen_db"  
)  
  
mycursor = mydb.cursor()  
  
sql = "INSERT INTO sites (name,url) VALUES (%s,%s)"  
val = ("youmen_db","https:/www.youmen.com")  
mycursor.execute(sql,val)  
  
mydb.commit()   # 数据表内容有更新，必须使用到该语句  
  
print(mycursor.rowcount,"记录插入成功.")  
  
1 记录插入成功.    

# 批量插入使用executemany()方法，该方法的第二个参数是一个元组列表，包含了我们要插入的数据  
import mysql.connector  
  
mydb = mysql.connector.connect(  
 host="116.196.83.113",   
 user="root",   
 passwd="ZHOUjian.21",  
 database="youmen_db"  
)  
  
mycursor = mydb.cursor()  
  
sql = "INSERT INTO sites (name,url) VALUES (%s,%s)"  
val = [  
 ("youmen_db","https://www.youmen.com"),  
 ("GitHub","https://www.github.com"),  
 ("Taobao","https://www.taobao.com"),  
]  
mycursor.executemany(sql,val)  
  
mydb.commit()   # 数据表内容有更新，必须使用到该语句  
  
print(mycursor.rowcount,"记录插入成功.")  
3 记录插入成功.  
# 如果想要数据记录插入后，获取该记录的ID,可以使用以下代码:  
# print(mycursor.rowcount,"记录插入成功.",mycursor.lastrowid)  
# 3 记录插入成功. 5  

# 查询数据使用SELECT语句  
import mysql.connector  
  
mydb = mysql.connector.connect(  
 host="116.196.83.113",   
 user="root",   
 passwd="ZHOUjian.21",  
 database="youmen_db"  
)  
  
mycursor = mydb.cursor()  
  
mycursor.execute("SELECT * FROM sites")  
  
myresult = mycursor.fetchall()  # fetchall()获取所有记录  
  
for i in myresult:  
 print(i)  
  
('youmen_db', 'https:/www.youmen.com', 1)  
('youmen_db', 'https://www.youmen.com', 2)  
('GitHub', 'https://www.github.com', 3)  
('Taobao', 'https://www.taobao.com', 4)  
  
# 也可以只读取指定字段数据  
# 将mycursor.execute("SELECT *  FROM sites")当中的* 换成你需要查看的字段即可.如果有多个字段,','隔开  

# 只查询一条数据  
import mysql.connector  
  
mydb = mysql.connector.connect(  
 host="116.196.83.113",   
 user="root",   
 passwd="ZHOUjian.21",  
 database="youmen_db"  
)  
  
mycursor = mydb.cursor()  
mycursor.execute("SELECT * FROM sites")  
myresult = mycursor.fetchone()  # fetchall()获取所有记录  
print(myresult)  
  
('youmen_db', 'https:/www.youmen.com', 1)  

# 读取name字段为youmen_db的记录：  
import mysql.connector  
  
mydb = mysql.connector.connect(  
 host="116.196.83.113",   
 user="root",   
 passwd="ZHOUjian.21",  
 database="youmen_db"  
)  
  
mycursor = mydb.cursor()  
sql = "SELECT * FROM sites WHERE name = 'youmen_db'"  
# 此处条件查找可以使用通配符  
# `sql = "SELECT * FROM sites WHERE url LIKE '%men%'"`  
  
mycursor.execute(sql)  
myresult = mycursor.fetchall()  
for x in myresult:  
 print(x)  
  
  
('youmen_db', 'https:/www.youmen.com', 1)  
('youmen_db', 'https://www.youmen.com', 2)  
('youmen_db', 'https://www.youmen.com', 5)  

import mysql.connector  
  
mydb = mysql.connector.connect(  
 host="116.196.83.113",   
 user="root",   
 passwd="ZHOUjian.21",  
 database="youmen_db"  
)  
  
mycursor = mydb.cursor()  
sql = "SELECT * FROM sites WHERE name = %s"  
na = ("youmen_db",)  
mycursor.execute(sql,na)  
myresult = mycursor.fetchall()  
for x in myresult:  
 print(x)  
  
('youmen_db', 'https:/www.youmen.com', 1)  
('youmen_db', 'https://www.youmen.com', 2)  
('youmen_db', 'https://www.youmen.com', 5)  

# 按name字段字母的升序排序  
import mysql.connector  
  
mydb = mysql.connector.connect(  
 host="116.196.83.113",   
 user="root",   
 passwd="ZHOUjian.21",  
 database="youmen_db"  
)  
  
mycursor = mydb.cursor()  
sql = "SELECT * FROM sites ORDER BY name"  
mycursor.execute(sql)  
myresult = mycursor.fetchall()  
for i in myresult:  
 print(i)  
  
('GitHub', 'https://www.github.com', 3)  
('GitHub', 'https://www.github.com', 6)  
('Taobao', 'https://www.taobao.com', 4)  
('Taobao', 'https://www.taobao.com', 7)  
('youmen_db', 'https:/www.youmen.com', 1)  

# 按name字段字母的升序排序  
import mysql.connector  
  
mydb = mysql.connector.connect(  
 host="116.196.83.113",   
 user="root",   
 passwd="ZHOUjian.21",  
 database="youmen_db"  
)  
  
mycursor = mydb.cursor()  
sql = "SELECT * FROM sites ORDER BY name DESC"  
mycursor.execute(sql)  
myresult = mycursor.fetchall()  
for i in myresult:  
 print(i)  
  
('youmen_db', 'https:/www.youmen.com', 1)  
('youmen_db', 'https://www.youmen.com', 2)  
('youmen_db', 'https://www.youmen.com', 5)  
('Taobao', 'https://www.taobao.com', 4)  
('Taobao', 'https://www.taobao.com', 7)  
('GitHub', 'https://www.github.com', 3)  

import mysql.connector  
  
mydb = mysql.connector.connect(  
 host="116.196.83.113",   
 user="root",   
 passwd="ZHOUjian.21",  
 database="youmen_db"  
)  
  
mycursor = mydb.cursor()  
sql = "SELECT * FROM sites LIMIT 3"  
# 从第二条开始读取前3条记录  
# sql = "SELECT * FROM sites LIMIT 3 OFFSET 1"   
  
mycursor.execute(sql)  
myresult = mycursor.fetchall()  
for i in myresult:  
 print(i)  
  
('youmen_db', 'https:/www.youmen.com', 1)  
('youmen_db', 'https://www.youmen.com', 2)  
('GitHub', 'https://www.github.com', 3)  

# 删除name为youmen_db的记录  
import mysql.connector  
  
mydb = mysql.connector.connect(  
 host="116.196.83.113",   
 user="root",   
 passwd="ZHOUjian.21",  
 database="youmen_db"  
)  
  
mycursor = mydb.cursor()  
sql = "DELETE FROM sites WHERE name = 'youmen_db'"  
  
# 为了防止数据库查询发生SQL注入的攻击，我们可以使用%s占位符来转义删除语句的条件.  
# sql = "DELETE FROM sites WHERE name = %s"  
# na = ("youmen_db",)  
# mycursor.execute(sql,na)  
  
mycursor.execute(sql)  
mydb.commit()  
print(mycursor.rowcount,"条记录删除")  
  
3 条记录删除  
  
# 慎重使用删除语句，删除语句要确保指定了WHERE条件语句，否则会导致整表数据被删除.  

import mysql.connector  
  
mydb = mysql.connector.connect(  
 host="116.196.83.113",   
 user="root",   
 passwd="ZHOUjian.21",  
 database="youmen_db"  
)  
  
mycursor = mydb.cursor()  
sql = "UPDATE sites SET name = '%ao%' WHERE name = 'ZHOU'"  
mycursor.execute(sql)  
mydb.commit()  
print(mycursor.rowcount, " 条记录被修改")  
  
# UPDATE语句确保了指定WHERE条件语句，否则会导致整表数据被更新  
# 为了防止数据库查询发生SQL注入情况，我们可以使用%s占位符来转义更新语句的条件:  

import mysql.connector  
  
mydb = mysql.connector.connect(  
 host="116.196.83.113",   
 user="root",   
 passwd="ZHOUjian.21",  
 database="youmen_db"  
)  
  
mycursor = mydb.cursor()  
sql = "UPDATE sites SET name = %s WHERE name = %s"  
val = ("GitHub","ZHOU")  
mycursor.execute(sql,val)  
mydb.commit()  
print(mycursor.rowcount, " 条记录被修改")  

import mysql.connector  
  
mydb = mysql.connector.connect(  
 host="116.196.83.113",   
 user="root",   
 passwd="ZHOUjian.21",  
 database="youmen_db"  
)  
  
mycursor = mydb.cursor()  
sql = 'DROP TABLE IF EXISTS sites' # 删除数据表sites  
mycursor.execute(sql)  

pip3 install PyMySQL

$ git clone https://github.com/PyMySQL/PyMySQL
$ cd PyMySQL/
$ python3 setup.py install

$ # X.X 为 PyMySQL 的版本号
$ curl -L https://github.com/PyMySQL/PyMySQL/tarball/pymysql-X.X | tar xz
$ cd PyMySQL*
$ python3 setup.py install
$ # 现在你可以删除 PyMySQL* 目录

# 安装的过程中可能会出现"ImportError: No module named setuptools"的错误提示，
# 意思是你没有安装setuptools，你可以访问
# [https://pypi.python.org/pypi/setuptools]找到各个系统的安装方法。

# Linux系统安装实例:
$ wget https://bootstrap.pypa.io/ez_setup.py
$ python3 ez_setup.py

# 连接数据库前，请先确认以下事项:
# 在你的机上安装了Python MySQLdb模块:

import pymysql
# 打开数据库连接
db = pymysql.connect("116.196.83.113","root","ZHOUjian.21")

# 使用cursor()方法创建一个游标对象cursor
cursor = db.cursor()

# 使用execute() 方法执行SQLc查询
cursor.execute("SELECT VERSION()")

# 使用fetchone()方法获取单条数据.
data = cursor.fetchone()
print("Database version: %s" % data)

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


Database version: 5.7.23

import pymysql
# 打开数据库连接
db = pymysql.connect("116.196.83.113","root","ZHOUjian.21")

# 使用cursor()方法创建一个游标对象cursor
cursor = db.cursor()

# 使用execute() 方法执行SQLc查询
cursor.execute("CREATE DATABASE youmen_db")

import pymysql
# 打开数据库连接
db = pymysql.connect("116.196.83.113","root","ZHOUjian.21","youmen_db")

# 使用cursor()方法创建一个游标对象cursor
cursor = db.cursor()

# 使用execute() 方法执行SQL,如果存在则删除
cursor.execute("DROP TABLE IF EXISTS NOTES")

# 使用预处理语句创建表
sql = """CREATE TABLE NOTES (
         FIRST_NAME  CHAR(20) NOT NULL,
         LAST_NAME  CHAR(20),
         AGE INT,  
         SEX CHAR(1),
         INCOME FLOAT )"""
 
cursor.execute(sql)

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

import pymysql
# 打开数据库连接
db = pymysql.connect("116.196.83.113","root","ZHOUjian.21","youmen_db")

# 使用cursor()方法创建一个游标对象cursor
cursor = db.cursor()

# 使用cursor()方法获取操作游标 
cursor = db.cursor()
 
# SQL 插入语句
sql = """INSERT INTO NOTES(FIRST_NAME,
         LAST_NAME, AGE, SEX, INCOME)
         VALUES ('Mac', 'DELL', 20, 'M', 2000)"""
try:
   # 执行sql语句
   cursor.execute(sql)
   # 提交到数据库执行
   db.commit()
except:
   # 如果发生错误则回滚
   db.rollback()
 
# 关闭数据库连接
db.close()

import pymysql
# 打开数据库连接
db = pymysql.connect("116.196.83.113","root","ZHOUjian.21","youmen_db")

# 使用cursor()方法创建一个游标对象cursor
cursor = db.cursor()

# 使用cursor()方法获取操作游标 
cursor = db.cursor()
 
# SQL 插入语句
sql = "INSERT INTO NOTES(FIRST_NAME,
    LAST_NAME,AGE,SEX,INCOME) 
    VALUES ('%s','%s',%s,'%s',%s)" % 
    ('air','level',21,'M',1999)

try:
    # 执行SQL语句
    cursor.execute(sql)
    # 执行sql语句
    db.commit()
except:
    # 发生错误时回滚
    db.rollback()

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

..................................
user_id = "test123"
password = "password"

con.execute('insert into Login values( %s,  %s)' % 
             (user_id, password))
..................................

import pymysql
# 打开数据库连接
db = pymysql.connect("116.196.83.113","root","ZHOUjian.21","youmen_db")


# 使用cursor()方法获取操作游标 
cursor = db.cursor()
 
# SQL 查询语句
sql = "SELECT * FROM EMPLOYEE 
       WHERE INCOME > %s" % (1000)
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 获取所有记录列表
   results = cursor.fetchall()
   for row in results:
      fname = row[0]
      lname = row[1]
      age = row[2]
      sex = row[3]
      income = row[4]
       # 打印结果
      print ("fname=%s,lname=%s,age=%s,sex=%s,income=%s" % 
             (fname, lname, age, sex, income ))

except:
   print ("Error: unable to fetch data")
 
# 关闭数据库连接
db.close()

# 脚本执行结果如下:
fname=Mac, lname=Mohan, age=20, sex=M, income=2000

import pymysql
# 打开数据库连接
db = pymysql.connect("116.196.83.113","root","ZHOUjian.21","youmen_db")


# 使用cursor()方法获取操作游标 
cursor = db.cursor()
 
# SQL 更新语句
sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '%c'" % ('M')
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 提交到数据库执行
   db.commit()
except:
   # 发生错误时回滚
   db.rollback()
 
# 关闭数据库连接
db.close()

import pymysql
# 打开数据库连接
db = pymysql.connect("116.196.83.113","root","ZHOUjian.21","youmen_db")

# 使用cursor()方法获取操作游标 
cursor = db.cursor()
 
# SQL 删除语句
sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (20)
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 提交修改
   db.commit()
except:
   # 发生错误时回滚
   db.rollback()
 
# 关闭连接
db.close()

import pymysql
# 打开数据库连接
db = pymysql.connect("116.196.83.113","root","ZHOUjian.21","youmen_db")

# 使用cursor()方法获取操作游标 
cursor = db.cursor()
 
# SQL删除记录语句
sql = "DELETE FROM NOTES WHERE AGE > %s" % (20)
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 向数据库提交
   db.commit()
except:
   # 发生错误时回滚
   db.rollback()

import pymysql

class DB():
    def __init__(self, host='localhost', port=3306, db='', user='root', passwd='root', charset='utf8'):
        # 建立连接 
        self.conn = pymysql.connect(host=host, port=port, db=db, user=user, passwd=passwd, charset=charset)
        # 创建游标，操作设置为字典类型        
        self.cur = self.conn.cursor(cursor = pymysql.cursors.DictCursor)

    def __enter__(self):
        # 返回游标        
        return self.cur

    def __exit__(self, exc_type, exc_val, exc_tb):
        # 提交数据库并执行        
        self.conn.commit()
        # 关闭游标        
        self.cur.close()
        # 关闭数据库连接        
        self.conn.close()


if __name__ == '__main__':
    with DB(host='192.168.68.129',user='root',passwd='zhumoran',db='text3') as db:
        db.execute('select * from course')
        print(db)
        for i in db:
            print(i)