数据库交互（总结）

防SQL注入知乎详解

常用数据库交互代码

mysql

import pymysql

class database(object):
    def __init__(self):
        '''-----connection连接点------cursor光标-----'''
        self.conn = pymysql.connect(host='localhost',port=3306,database='数据库名',user='root',password='1',charset='utf8')
        self.cs = self.conn.cursor()
    def database_Mysql(self,inf):
        '''添加数据（字典）'''
        sql = 'insert into qidian({}) values({})'.format(','.join(inf.keys()), ','.join(['%s'] * len(inf)))
        try:
            count = self.cs.execute(sql, [value for key, value in inf.items()])#不用list(inf.values())防sql注入
            print('ok')
            self.conn.commit()
        except Exception as err:
            print(err)
            self.conn.rollback()
if __name__ == '__main__':
    database()

mongo

• mongo知识大全

import pymongo

class database(object):
    def __init__(self):
        '''-----client客户端-----[数据库][集合]-----'''
        self.client = pymongo.MongoClient('localhost',27017)
        self.db = self.client['数据库名字']
        self.set = self.db['集合名字']
    def database_Mongo(self,info):
        '''添加数据（字典）'''
        self.col.insert(info)

---

redis 配置
主从（信息唯一）
集群（信息共享）
redis（mysql交互）

redis

import redis