import pymysql # user = input('请输入用户名：') # pwd = input('请输入密码：') # 1.创建连接 conn = pymysql.connect(host='127.0.0.1', user='root', password="", database='db8', port=3306, charset='utf8') # 2.创建游标 cur = conn.cursor(cursor=pymysql.cursors.DictCursor) # sql = "select * from userinfo where name='%s' and pwd='%s'" %(user,pwd) # sql = "select * from userinfo where name=%s and pwd=%s" # sql = "select * from userinfo where name=%(user)s and pwd=%(pwd)s" # 插入数据 # sql = 'insert into userinfo(name,pwd) values(%s,%s)' # print(sql) # 3执行sql语句 # r = cur.execute(sql,[user,pwd]) # r = cur.execute(sql,(user,pwd)) # r = cur.execute(sql,{"user":user,"pwd":pwd}) #插入多条数据 # r = cur.executemany(sql, [('李四', '110'), ('王五', '119')]) # print(r) sql = 'select * from userinfo' cur.execute(sql) # row = cur.fetchone() # print(row) # row = cur.fetchone() # print(row) # row = cur.fetchone() # print(row) # row = cur.fetchone() # print(row) # row = cur.fetchone() # print(row) # rows = cur.fetchmany() # # print(rows) rows = cur.fetchall() print(rows) # 增 删 改 一定要提交 conn.commit() # 关闭游标 关闭连接对象 cur.close() conn.close() # if r: # print('查询成功') # else: # print('查询失败')