数据库相关操作

一、前提

  在 cmd 中已执行 pip install pymysql  安装完成 数据库(mysql )模块

二、引入pymysql,并连接数据库

 数据库连接

 1 import pymysql
 2 
 3 conn = pymysql.connect(
 4                 host="*.*.*.*",#数据库IP
 5                 user="*",#数据库的用户名
 6                 password="*",#密码
 7                 db="*",#数据库名
 8                 port=3306,#数据库端口(默认端口)
 9                 charset="utf8",#字符集
10                 autocommit=True #自动提交
11                 )#连接数据库

三、执行SQL语句存储数据 及 关闭数据库连接

  1. 获取游标并执行SQL语句

    callproc(self, procname, args):用来执行存储过程,接收的参数为存储过程名和参数列表,返回值为受影响的行数
    execute(self, query, args):执行单条sql语句,接收的参数为sql语句本身和使用的参数列表,返回值为受影响的行数
    executemany(self, query, args):执行单条sql语句,但是重复执行参数列表里的参数,返回值为受影响的行数
    nextset(self):移动到下一个结果集

1 cursor = conn.cursor(pymysql.cursors.DictCursor) #建立游标
2 cursor.execute('insert into students (name,phone,age,sex) values ("张三","15975325689",20,"南");' )#
3 cursor.execute('update students set name = "万书成" where id = 20')#
4 cursor.execute("select * from students;") #
5 conn.commit() #提交,若连接数据时已设置自动提交,则不需要执行再次执行提交,否则需要提交才能真正执行sql语句

  2. 结果返回

1 #   result =cursor.fetchall()# 获取数据库执行结果
2 #   result =cursor.fetchmany(3)# 指定获取数据库几条执行结果
3 #   result =cursor.fetchone()# 仅获取数据库1条执行结果
4 #   print(result)
5 print("===========数据较多时,使用以下=================")
6 for line in cursor:
7     print(line)

  3. 关闭连接数据库

1 cursor.close()
2 conn.close()
原文地址:https://www.cnblogs.com/huajie-chj/p/14324566.html