[学习笔记] pymysql入门

import pymysql
 
# 连接数据库
conn = pymysql.connect(
    host=“数据库地址(localhost)”,
    user=“用户名”,
    password=“密码”,
    database=“数据库名”,
    charset=“utf8”)
 
# 得到一个可以执行SQL语句的光标对象且结果集默认以元组显示
cursor = conn.cursor() 
# 得到一个可以执行SQL语句并且将结果作为字典返回的游标
#cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
 
# 定义要执行的SQL语句
sql = """
create table fav_table
(
    id INT auto_increment primary key,
    user VARCHAR(128),
    ess INT
)CHARACTER SET utf8;
"""

cursor.execute(sql)
#对数据库进行写操作要提交（建表不算）
#conn.commit()
cursor.close()
conn.close()

import pymysql
 
conn = pymysql.connect(
    host=‘主机IP(或localhost)‘,
    port=端口号,
    user=‘root‘,
    password=‘123456‘,
    database=‘数据库名‘,
    charset=‘utf8‘
)
cursor = conn.cursor()


#sql =‘insert into userinfo (user,ess) values (%s,%s);‘
#user = ‘user_1‘
#ess = 1
#cursor.execute(sql, [name, ess])


sql = ‘insert into userinfo(user,ess) values(%s,%s);‘
data = [
    (‘user_1‘, 110),
    (‘user_2‘, 120),
    (‘user_3‘, 479)
]
# 拼接并执行sql语句
cursor.executemany(sql, data)

conn.commit()
cursor.close()
conn.close()

#views.py

import pymysql
from django.http import HttpResponse

def add_fav(request):
    conn = pymysql.connect(
    host=‘localhost‘,
    user=‘root‘,
    password=‘buzhidao‘,
    database=‘wapp_shuer‘,
    charset=‘utf8‘
    )
　　　　
    user = request.POST.get(‘re_user‘)    
    ess = request.POST.get(‘re_ess‘)
    data = [user,ess]

    cursor = conn.cursor()
    sql = "insert into fav_table (user, ess) value (%s, %s);"
    res = cursor.execute(sql,data)
    conn.commit()
    cursor.close()
    conn.close()
    return HttpResponse(res)