安裝PyMysql

安裝PyMysql：Py3默認自帶pip3安裝，Py2默認無pip命令

cmd進入PyCharm的安裝目錄完成安裝 pip3 install pymysql

安裝完成的位置：E:\PyCharm 2017.2.4\Python3.2.5\Lib\site-packages

故障處理：更新一下默認的Python安裝

Py下操作Mysql

PyMySQL- 專門用于操作MySQLpython模塊, Py2和Py3同時兼容

- MySQLdb(py3暫時不支持MySQLdb)

基本操作：添加信息——Insert# -*- coding:utf-8 -*-

import pymysql

# 創(chuàng)建連接

conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='', db='test_python', charset='utf8')

# 創(chuàng)建游標

cursor = conn.cursor() # 默認是元組，可以更改為字典類型

# 第一種：直接插入

# 執(zhí)行SQL，并返回受影響行數(shù)

insert_effect_row = cursor.execute("insert into course(cname, teacher_id) VALUES ('hhhh43hhkkhh', '2')")

inp = input('請輸入姓名：')

inp2 = input('請輸入教師ID：')

# 第二種：字符串拼接

# sql = 'insert into course(cname) VALUES ("%s")' %inp

# cursor.execute(sql) # 字符串拼接可以用，但是容易造成sql注入不推薦使用

# 第三種：參數(shù)傳遞，利用%s做占位符號，傳入?yún)?shù)進去，PyMysql內(nèi)部幫我們轉(zhuǎn)換

insert_effect_row_sec = cursor.execute("insert into course(cname, teacher_id) VALUES (%s, %s)", (inp, inp2)) # 參數(shù)傳遞

# 第四種： 多條信息的插入

li = [

('哇哈哈1', 1),

('哇哈哈2', 2),

('哇哈哈3', 3),

]

executmany = cursor.executemany("insert into course(cname, teacher_id) VALUES (%s, %s)", li) # 傳入可迭代的類型

print('executmany:', executmany) # executmany: 3 ，修改成功3條

# 提交，不然無法保存新建或者修改的數(shù)據(jù)

conn.commit()

# 關(guān)閉游標

cursor.close()

# 關(guān)閉連接

conn.close()

基本操作：查找信息——Select# -*- coding:utf-8 -*-

import pymysql

# 創(chuàng)建連接

conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='', db='test_python', charset='utf8')

# 創(chuàng)建游標

cursor = conn.cursor()

ret = cursor.execute('select * from student') # 僅僅數(shù)據(jù)加載到內(nèi)存，需要fetch取值

print(ret) # 查找到結(jié)果的數(shù)量

# 第一種： 直接打印,數(shù)據(jù)量大的時候容易導(dǎo)致內(nèi)存不夠用(內(nèi)部有一個指針索引)

# r = cursor.fetchall()

# print('取出所有值\n', r) # 打印結(jié)果，結(jié)果是一個元組

# 第二種： 從內(nèi)存中取出來1條數(shù)據(jù)，此時數(shù)據(jù)已經(jīng)加載到內(nèi)存

r1 = cursor.fetchone()

print('拿出一個\n:', r1)

# 第三種： 從內(nèi)存中取出來3條數(shù)據(jù)，此時數(shù)據(jù)已經(jīng)加載到內(nèi)存

r3 = cursor.fetchmany(3)

print('拿出三個\n:', r3)

# 第四種：操作指針取出數(shù)據(jù)

# cursor.scroll(0, mode='relative') # 相對位置，指針索引回歸0， +1/-1 分別表示向上/向下

# r4 = cursor.fetchmany(3)

# print('相對索引拿出三個\n:', r4) # 從第5個開始取值 : ((5, '女', 1, '張二'), (6, '男', 1, '張四'), (7, '女', 2, '鐵錘'))

cursor.scroll(0, mode='absolute') # 絕對位置，指針索引回歸0

r5 = cursor.fetchmany(3)

print('絕對索引拿出三個\n:', r5) # 從第0個位置開始取值: ((1, '男', 1, '理解'), (2, '女', 1, '鋼蛋'), (3, '男', 1, '張三'))

# 關(guān)閉游標

cursor.close()

# 關(guān)閉連接

conn.close()

基本操作：更改信息——Update# -*- coding:utf-8 -*-

import pymysql

# 創(chuàng)建連接

conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='', db='test_python', charset='utf8')

# 創(chuàng)建游標

cursor = conn.cursor()

inp = input('請輸入更新后的信息：')

ret = cursor.execute("update course set cname = %s where cname = '哇哈哈4'", inp)

ret2 = cursor.execute("update course set cname = %s where cname = '哇哈哈1'", inp)

# 提交，不然無法保存新建或者修改的數(shù)據(jù)

conn.commit()

print('不存在且更新結(jié)果：', ret, '\r\n存在且更新結(jié)果：', ret2)

# 關(guān)閉游標

cursor.close()

# 關(guān)閉連接

conn.close()

基本操作：刪除信息——Delete# -*- coding:utf-8 -*-

import pymysql

# 創(chuàng)建連接

conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='', db='test_python', charset='utf8')

# 創(chuàng)建游標

cursor = conn.cursor()

inp = input('請輸入更新后的信息：')

ret = cursor.execute("update course set cname = %s where cname = '哇哈哈4'", inp)

ret2 = cursor.execute("update course set cname = %s where cname = '哇哈哈1'", inp)

# 提交，不然無法保存新建或者修改的數(shù)據(jù)

conn.commit()

print('不存在且更新結(jié)果：', ret, '\r\n存在且更新結(jié)果：', ret2)

# 關(guān)閉游標

cursor.close()

# 關(guān)閉連接

conn.close()

其他操作： 更改游標的返回值為字典# -*- coding:utf-8 -*-

import pymysql

# 創(chuàng)建連接

conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='', db='test_python', charset='utf8')

# 創(chuàng)建游標

cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)

cursor.execute('select cid as id , cname as name from course') # 可以更改原理字典的key[cname]為name

print(cursor.fetchall()) # 可以根據(jù)字典取值

# 關(guān)閉游標

cursor.close()

# 關(guān)閉連接

conn.close()

其他操作：獲取自增ID#!/usr/bin/env python

# -*- coding:utf-8 -*-

import pymysql

conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='', db='test_python', charset='utf8')

cursor = conn.cursor()

cursor.executemany("insert into course(cname, teacher_id)values(%s,%s)", [("百事可樂", 1), ("可口可樂", 2)])

conn.commit()

# 獲取最新自增ID

new_id = cursor.lastrowid

print(new_id)

cursor.close()

conn.close()

防SQL注入的方法

防SQL注入的方法：

1. 存儲過程

2. 占位符拼接? 切記用字符串拼接

SQL注入：更改了原來的sql語句，不推薦拼接，推薦參數(shù)傳遞# -*- coding:utf-8 -*-

import pymysql

# 創(chuàng)建連接

conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='', db='test_python', charset='utf8')

# 創(chuàng)建游標

cursor = conn.cursor()

sql = 'select * from course where cid = "%s" and cname = "%s"'

# sql = sql % ('24', '哇哈哈3') # 正常

sql = sql % ('24"-- ', '哇哈哈3') # SQL注入取值,注釋掉了后面的內(nèi)容

# sql = sql % ('24" or 1=1 -- ', '哇哈哈3') # SQL注入取值,后面的條件恒成立，可查詢所有結(jié)果

print(sql)

ret = cursor.execute(sql);

r = cursor.fetchall()

print('執(zhí)行結(jié)果：', r)

# 關(guān)閉游標

cursor.close()

# 關(guān)閉連接

conn.close()

總結(jié)

以上是生活随笔為你收集整理的mysql1231错误_Mysql学习---Python操作Mysql 1231的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。