做网站是什么职位,网页首站,小程序商城怎么开通,天津武清做网站的公司python 实现对数据库的ORM 映射
如果使用pymysql 操作数据库 不借助框架的话#xff0c;频繁写sql语句, 的确比较麻烦 这里借助 type 元类 对 数据表类实现了 与mysql之间的 映射
直接上代码
import pymysqldef conn_database_execute(sql_str):conn pymysql.connect(host…python 实现对数据库的ORM 映射
如果使用pymysql 操作数据库 不借助框架的话频繁写sql语句, 的确比较麻烦 这里借助 type 元类 对 数据表类实现了 与mysql之间的 映射
直接上代码
import pymysqldef conn_database_execute(sql_str):conn pymysql.connect(hostlocalhost, port3306, userroot, password123, databaseit_test,charsetutf8)cus conn.cursor()get_exist_tables show tables;cus.execute(get_exist_tables)ret cus.fetchall()print(ret)if sql_str.startswith(create):sql_str_list sql_str.split( )print(sql_str_list)table_name sql_str_list[2]if not (table_name,) in ret:print( create a table )cus.execute(sql_str)else:cus.execute(sql_str)print()print(sql_str)print()cus.close()conn.close()class MetaClassModel(type):def __new__(cls, cls_name, args, kwargs):mapping dict()field_name_explain dict()for k, v in kwargs.items():if isinstance(v, tuple):mapping[k] vfield_name_explain[ v[0] ] v[1]for k in mapping.keys():kwargs.pop(k)kwargs[mapping_] mapping# mapping_ {# user_id (user_id, int unsigned auto_increment primary key not null),# name (name, varchar(20))# age (age, int unsigned)# }kwargs[table_] cls_nameif cls_name ! Model:sql_str_1 for field_name, field_explain in field_name_explain.items():print(type(field_name))print(type(field_explain))sql_str_1 field_name field_explain ,sql_str_1 sql_str_1[:-1]create_sql_str create table %s (%s); %(cls_name, sql_str_1)print(create_sql_str)conn_database_execute(create_sql_str)return type.__new__(cls, cls_name, args, kwargs)class Model(metaclassMetaClassModel):def __init__(self, **kwargs):for name, value in kwargs.items():setattr(self, name, value)def save(self):files []args []for key, vaule in self.mapping_.items():files.append(vaule[0])# 获取通过构造方法 里面 setattr设置的参数valueargs.append(getattr(self, key, None))args_temp list()for temp in args:if isinstance(temp, int):args_temp.append(str(temp))elif isinstance(temp, str):args_temp.append(%s%temp)sql_str insert into %s (%s) values (%s);%(self.table_, ,.join(files), ,.join(args_temp))print(sql_str)conn_database_execute(sql_str)class User(Model):user_id (user_id, int unsigned auto_increment primary key not null)name (name, varchar(20))age (age, int unsigned)# mapping_ {# user_id (user_id, int unsigned auto_increment primary key not null),# name (name, varchar(20))# age (age, int unsigned)# }# user_1 User(user_id0, nameWangMing, age6)
# user_1.save()
# user_2 User(user_id0, nameLiQiang, age7)
# user_2.save()
class SuperUser(Model):user_id (user_id, int unsigned auto_increment primary key not null)name (name, varchar(20))age (age, int unsigned)user_2 User(user_id0, nameMengTing, age7)
user_2.save()只要定义一个类继承 Model类 就可以在数据库中创建相应的表 但是还有个问题user.save() 明明生成了正确的sql语句 却没有成功插入不知道怎么回事 希望路过的大哥告诉我一下小弟不胜感激
