from jdbcdao.iwapper import IWapper
from jdbcdao.iconnection import Iconnect
'''jdbc数据库操作模板'''
class JdbcTemplate(object):
def __init__(self,iconnect:Iconnect):
self.iconnect = iconnect
def ddl(self, sql):
conn = self.iconnect.get_connect()
cursor = conn.cursor()
cursor.execute(sql)
conn.commit()
self.__close_conn(conn)
def dml(self, sql):
conn = self.iconnect.get_connect()
cursor = conn.cursor()
cursor.execute(sql)
conn.commit()
self.__close_conn(conn)
print("dml success")
def dql(self, sql, wapper:IWapper) -> list:
conn = self.iconnect.get_connect()
cursor = conn.cursor()
c = cursor.execute(sql)
result_set = cursor.fetchall()
datas = []
for row in result_set:
row_data = wapper.wapper(row)
datas.append(row_data)
self.__close_conn(conn)
return datas
def __close_conn(self,conn):
self.iconnect.close_conncet(conn)
jdbcdao.zip （16个子文件） 
jdbcdao 
iconnection.py 175B __pycache__ __init__.cpython-38.pyc 133B iwapper.cpython-38.pyc 519B iconnection.cpython-38.pyc 631B jdbctemplate.cpython-38.pyc 2KB iwapper.py 98B __init__.py 0B database.db 16KB impl oracleconnection.py 428B __pycache__ __init__.cpython-38.pyc 138B sqliteconnection.cpython-38.pyc 744B mysqlconnection.cpython-38.pyc 860B sqliteconnection.py 361B __init__.py 0B mysqlconnection.py 498B jdbctemplate.py 1KB资源评论
