(executor, dbName: str, sql: str)
| 215 | return dataT.get(dataType, None) |
| 216 | |
| 217 | def select(executor, dbName: str, sql: str): |
| 218 | log.info("select sql:"+sql) |
| 219 | fesqlResult = FesqlResult() |
| 220 | try: |
| 221 | rs = executor.execute(sql) |
| 222 | fesqlResult.ok = True |
| 223 | fesqlResult.msg = "ok" |
| 224 | fesqlResult.rs = rs |
| 225 | fesqlResult.count = rs.rowcount |
| 226 | fesqlResult.result = convertRestultSetToListRS(rs) |
| 227 | except Exception as e: |
| 228 | log.info("select exception is {}".format(e)) |
| 229 | fesqlResult.ok = False |
| 230 | fesqlResult.msg = str(e) |
| 231 | log.info("select result:"+str(fesqlResult)) |
| 232 | return fesqlResult |
| 233 | |
| 234 | def formatSql(sql:str,tableNames:list): |
| 235 | if "{auto}" in sql: |
no test coverage detected