python学习之PyMySql 3 添加

首先我们查看所有的数据

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)))
然后我们可以看到我们插入成功了,并且得到了插入后的结果。






猜你喜欢

转载自blog.csdn.net/rubikchen/article/details/80527783