因为链接数据库的方式比较固定,所以我们把它封装成一个函数,以后用的时候,直接copy就OK了,代码如下:
import pymysql mysql_info = { "host":"110.10.**.**",#数据库IP "user":"jxz",#数据库用户名 "passwd":"****",#密码 "db":"jxz",#要连接的数据名字 "port":3306, "charset":"utf8",#字符集 "autocommit":True } def execute_sql(sql,all=True,cur_type=1): #cur_type如果是1,那么返回的是list #如果是2,那么返回的字典 connect = pymysql.connect(**mysql_info)#链接数据库 cur = connect.cursor() if cur_type == 1 else connect.cursor(pymysql.cursors.DictCursor)# 使用 cursor() 方法创建一个游标对象 cursor,指定成字典形式 cur.execute(sql)# 执行sql语句 if all: result = cur.fetchall()#显示全部查询结果,输出形式为二维数组 else: result = cur.fetchone()#执行一条,输出形式为list cur.close()#关闭游标 connect.close()#关闭数据库 return result
这个看着要是比较难,我们还有容易看懂的连接方式哦……
import pymysql #程序包含的模块 db = pymysql.connect(host='110.40.**.**',user='jxz',password='123456',database='jxz')#连接数据库 cur = db.cursor() # 使用 cursor() 方法创建一个游标对象 cursor sql="select * from student_info where name='某某'"%uname cur.execute(sql)#执行sql db.commit()#记得一定要提交 cur.close()#关闭游标哦 db.close()#关闭数据库
执行后数据库中应该会新增一条数据