首先我们查看所有的数据
import pymysql import datetime try: db = pymysql.connect(host="127.0.0.1",user="root",port=3306,password="123456",database="android",charset="utf8") cursor = db.cursor() cursor.execute("select * from test") print(cursor.rowcount) print(cursor.fetchall()) db.close() except: print("连接失败")
1 (('aaa', datetime.datetime(2018, 5, 31, 0, 0)),)然后我们插入数据
import pymysql import datetime try: db = pymysql.connect(host="127.0.0.1",user="root",port=3306,password="123456",database="android",charset="utf8") cursor = db.cursor() cursor.execute("insert into test" " values(%s,%s)",("bbb",datetime.date(2018,5,31))) print(cursor.mogrify("insert into test" " values(%s,%s)",("bbb",datetime.date(2018,5,31)))) db.commit() print(cursor.rowcount) print(cursor.fetchall()) db.close() except: print("连接失败")
insert into test values('bbb','2018-05-31') 1 ()
我们可以看到我们插入成功了,在这里我们要注意的是 db.commit()如果我们不适用这个方法,我们在查询的时候就会得不到想要的结果。
import pymysql import datetime try: db = pymysql.connect(host="127.0.0.1",user="root",port=3306,password="123456",database="android",charset="utf8") cursor = db.cursor() # cursor.execute("insert into test" # " values(%s,%s)",("bbb",datetime.date(2018,5,31))) # print(cursor.mogrify("insert into test" # " values(%s,%s)",("bbb",datetime.date(2018,5,31)))) # db.commit() cursor.execute("select * from test") print(cursor.rowcount) print(cursor.fetchall()) db.close() except: print("连接失败")
2 (('aaa', datetime.datetime(2018, 5, 31, 0, 0)), ('bbb', datetime.datetime(2018, 5, 31, 0, 0)))这是我们插入后查询到的结果,在这里我们通过%s + tuple的方式进行execute映射。
import pymysql import datetime try: db = pymysql.connect(host="127.0.0.1",user="root",port=3306,password="123456",database="android",charset="utf8") cursor = db.cursor() data = {'id':"12345",'password':datetime.date(2018,5,31)} cursor.execute("insert into test" " values(%(id)s,%(password)s)",data) print(cursor.mogrify("insert into test" " values(%(id)s,%(password)s)",data)) db.commit() print(cursor.rowcount) print(cursor.fetchall()) db.close() except: print("连接失败")
insert into test values('12345','2018-05-31') 1 ()
我们可以看到我们插入成功了
import pymysql import datetime try: db = pymysql.connect(host="127.0.0.1",user="root",port=3306,password="123456",database="android",charset="utf8") cursor = db.cursor() cursor.execute("select * from test") print(cursor.rowcount) print(cursor.fetchall()) db.close() except: print("连接失败")
6 (('111', datetime.datetime(2018, 5, 31, 0, 0)), ('112', datetime.datetime(2018, 5, 31, 0, 0)), ('12345', datetime.datetime(2018, 5, 31, 0, 0)), ('aaa', datetime.datetime(2018, 5, 31, 0, 0)), ('bbb', datetime.datetime(2018, 5, 31, 0, 0)), ('ccc', datetime.datetime(2018, 5, 31, 0, 0)))然后我们可以看到我们插入成功了,并且得到了插入后的结果。