摘要：Python里面操作MySQL可以通過兩個方式:pymysql模塊ORM框架的SQLAchemey先學(xué)習(xí)第一種方式。學(xué)習(xí)Python模塊之前，首先看看MySQL的基本安裝和使用，具體語法可以參考豆子之前的博客http://beanxyz.blog.51cto.com/5570417/1609972或者官方簡介https://mariadb.com/kb/en/mariadb/basic-sql-s

Python里面操作MySQL可以通過兩個方式:

pymysql模塊

ORM框架的SQLAchemey

先學(xué)習(xí)第一種方式。

學(xué)習(xí)Python模塊之前，首先看看MySQL的基本安裝和使用，具體語法可以參考豆子之前的博客http://beanxyz.blog.51cto.com/5570417/1609972

或者官方簡介

https://mariadb.com/kb/en/mariadb/basic-sql-statements/

簡單的回顧一下基本環(huán)境的搭建：

首先安裝Mariadb（我的環(huán)境是CentOS7）

yum install mariadb*
systemctl start mariadb

配置防火墻

firewall-cmd --add-port=3306/tcp --permanent
systemctl restart firewalld

配置root密碼

mysqladmin -u root password 'mysql'
mysql -uroot -p

創(chuàng)建一個測試用的數(shù)據(jù)庫和表

MariaDB [(none)]> create database mydb;
Query OK, 1 row affected (0.00 sec)
 
MariaDB [(none)]> use mydb
Database changed
MariaDB [mydb]> create table student(id int not null auto_increment,name varchar(10), primary key(id));
Query OK, 0 rows affected (0.04 sec)
 
MariaDB [mydb]> insert into student(name) values('Jay'),('Bob'),('Alex');
Query OK, 3 rows affected (0.00 sec)
Records: 3  Duplicates: 0  Warnings: 0
 
MariaDB [mydb]> select * from student;
+----+------+
| id | name |
+----+------+
|  1 | Jay  |
|  2 | Bob  |
|  3 | Alex |
+----+------+
3 rows in set (0.00 sec)

創(chuàng)建一個遠程訪問的賬戶

MariaDB [(none)]> create user yli@10.2.100.60;
Query OK, 0 rows affected (0.00 sec)
MariaDB [(none)]> set password for yli@'10.2.100.60'=password('yli');
Query OK, 0 rows affected (0.01 sec)
MariaDB [(none)]> grant all privileges on mydb.* to yli@10.2.100.60;
Query OK, 0 rows affected (0.00 sec)

然后安裝一個圖形界面的工具Navicat,綁定數(shù)據(jù)庫

這樣一個基本的測試環(huán)境就搭建好了。

現(xiàn)在來看看pymysql的使用。

在我的客戶端安裝一下pymysql的模塊

C:\WINDOWS\system32>pip install pymysql
Collecting pymysql
  Downloading PyMySQL-0.7.9-py3-none-any.whl (78kB)
    100% |################################| 81kB 610kB/s
Installing collected packages: pymysql
Successfully installed pymysql-0.7.9

Python源碼演示

查詢

#!/usr/bin/env python
# -*- coding:utf-8 -*-
import pymysql
#打開數(shù)據(jù)庫連接
conn = pymysql.connect(host='sydnagios', port=3306, user='yli', passwd='yli', db='mydb')
#創(chuàng)建一個游標對象
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
#SQL查詢
cursor.execute("select * from student")
# 獲取第一行數(shù)據(jù)
# row_1 = cursor.fetchone()
# print(row_1)
# 獲取前n行數(shù)據(jù)
# row_2 = cursor.fetchmany(3)
# 獲取所有數(shù)據(jù)
row_3 = cursor.fetchall()
print(row_3)
#scroll可以使用相對位置或者絕對位置，這里相對位置（末尾）向上移動2行
cursor.scroll(-2,mode='relative')
row_3 = cursor.fetchall()
print(row_3)
#提交，不然無法保存新的數(shù)據(jù)
conn.commit()
#關(guān)閉游標
cursor.close()
#關(guān)閉連接
conn.close()
-----------
[{'id': 1, 'name': 'Jay'}, {'id': 2, 'name': 'Bob'}, {'id': 3, 'name': 'Alex'}]
[{'id': 2, 'name': 'Bob'}, {'id': 3, 'name': 'Alex'}]

修改

#!/usr/bin/env python
# -*- coding:utf-8 -*-
import pymysql
conn = pymysql.connect(host='sydnagios', port=3306, user='yli', passwd='yli', db='mydb')
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
cursor.execute("Update student set name='BoB' where id=2")
cursor.execute("select * from student")
row_3 = cursor.fetchall()
print(row_3)
conn.commit()
cursor.close()
conn.close()
----------
[{'id': 1, 'name': 'Chris'}, {'id': 2, 'name': 'BoB'}, {'id': 3, 'name': 'Alex'}]

刪除

#!/usr/bin/env python
# -*- coding:utf-8 -*-
import pymysql
conn = pymysql.connect(host='sydnagios', port=3306, user='yli', passwd='yli', db='mydb')
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
cursor.execute("delete from student where id=2")
cursor.execute("select * from student")
row_3 = cursor.fetchall()
print(row_3)
conn.commit()
cursor.close()
conn.close()
----------
[{'id': 1, 'name': 'Chris'}, {'id': 2, 'name': 'BoB'}, {'id': 3, 'name': 'Alex'}]

添加

#!/usr/bin/env python
# -*- coding:utf-8 -*-
import pymysql
conn = pymysql.connect(host='sydnagios', port=3306, user='yli', passwd='yli', db='mydb')
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
cursor.execute("insert into student(name) value ('ZhangSan'),('LiSi')")
cursor.execute("select * from student")
row_3 = cursor.fetchall()
print(row_3)
conn.commit()
cursor.close()
conn.close()
----------
[{'name': 'Chris', 'id': 1}, {'name': 'Alex', 'id': 3}, {'name': 'ZhangSan', 'id': 4}, {'name': 'LiSi', 'id': 5}]