From 20791b0d713dfb0e853a19ab84bbd27dcefb8412 Mon Sep 17 00:00:00 2001
From: yumoqing <yumoqing@gmail.com>
Date: Mon, 9 Oct 2023 16:11:02 +0800
Subject: [PATCH] bugfix

---
 sqlor/sor.py | 16 ++++++++++------
 1 file changed, 10 insertions(+), 6 deletions(-)

diff --git a/sqlor/sor.py b/sqlor/sor.py
index 083abf5..299dabd 100755
--- a/sqlor/sor.py
+++ b/sqlor/sor.py
@@ -230,15 +230,14 @@ class SQLor(object):
 		datas = self.dataConvert(datas)
 		try:
 			if self.async_mode:
-				await cursor.execute(markedSQL,datas)
+				return await cursor.execute(markedSQL,datas)
 			else:
-				cursor.execute(markedSQL,datas)
+				return cursor.execute(markedSQL,datas)
 
 		except Exception as e:
 			print( "markedSQL=",markedSQL,':',datas,':',e)
 			print_exc()
 			raise e
-		return 
 			
 	def maskingSQL(self,org_sql,NS):
 		"""
@@ -286,7 +285,7 @@ class SQLor(object):
 	async def execute(self,sql,value,callback,**kwargs):
 		sqltype = self.getSqlType(sql)
 		cur = self.cursor()
-		await self.runVarSQL(cur,sql,value)
+		ret = await self.runVarSQL(cur,sql,value)
 		if sqltype == 'qry' and callback is not None:
 			fields = [ i[0].lower() for i in cur.description ]
 			rec = None
@@ -306,6 +305,7 @@ class SQLor(object):
 					rec = cur.fetchone()
 		if sqltype == 'dml':
 			self.dataChanged = True
+			return ret
 
 	async def executemany(self,sql,values):
 		cur = self.cursor()
@@ -466,12 +466,16 @@ class SQLor(object):
 		await self.execute(sql,NS,callback)
 	
 	async def sqlExecute(self,desc,NS):
-		await self.execute(desc,NS,None)
+		return await self.execute(desc,NS,None)
 	
 	async def sqlExe(self,sql,ns):
 		ret = []
-		await self.execute(sql,ns,
+		r = await self.execute(sql,ns,
 			callback=lambda x:ret.append(x))
+		sqltype = self.getSqlType(sql)
+		if sqltype == 'dml':
+			return r
+
 		return ret
 
 	async def sqlPaging(self,sql,ns):