结合上篇的 连接数据库 然后呢 就进行下面的操作 over 简单易懂就够了。
import pymysql from testpy.mysqlconnection import MysqlConnection
#调用 class MysqlInsertDBS:
def select(): sql = "select t.turl,n.libs,n.nname,n.nurl,n.img from temp t left join node n on n.tempid =t.id" db = MysqlConnection.connsql() cursor=db.cursor() cursor.execute(sql) data=cursor.fetchall() for redu in data: return redu def insert(videoName, videoUrl, videoImg): db = MysqlConnection.connsql() cursor = db.cursor() sqli = "insert into spider(videoName,videoUrl,videoImg) values('%s','%s','%s')"%(videoName,videoUrl,videoImg) cursor.execute(sqli) db.commit() db.rollback() # 发生错误时回滚 cursor.close() if __name__=="__main__": select()
