mssqlDataset
import pymssql
class mssqlDatarow(object):
def init(self,fields,values):
self.fields=dict() for i in range(len(fields)):
self.
self.values=values
- fieldName=fieldName.upper()
if self.fields.has_key(fieldName): return self.fields[fieldName] else: return None
class mssqlDataset(object):
def init(self,cnt):
self.
- sqlSelect=sqlSelect.strip().upper() asFix=' as '.upper() asIndex=sqlSelect.rfind(asFix)
if asIndex<=0: return sqlSelect sqlSelect=sqlSelect[asIndex+len(asFix):] return sqlSelect
- s=sqlSelect.strip() s=s.split(",") self.fieldNames=map(self.getFieldNameOnSelectAs,s) ssql="select %s%s "%(sqlPre+" " if sqlPre else "",sqlSelect if sqlSelect else "") ssql+="\nfrom %s "%(sqlFrom if sqlFrom else "",) ssql+="\n%s "%("where "+sqlWhere if sqlWhere else "",) ssql+="\n%s "%("order by "+sqlOrder if sqlOrder else "",) ssql+="\n%s"%("group by "+sqlGroup if sqlGroup else "",)
cur=self.cnt.cursor() cur.execute(ssql) fetches=cur.fetchall() cur.close() self.rows=list() for fetch in fetches:
- self.rows.append(mssqlDatarow(self.fieldNames,fetch))