(sql:str,tableNames:list)
| 232 | return fesqlResult |
| 233 | |
| 234 | def formatSql(sql:str,tableNames:list): |
| 235 | if "{auto}" in sql: |
| 236 | sql = sql.replace("{auto}", getRandomName()) |
| 237 | if "{tb_endpoint_0}" in sql: |
| 238 | sql = sql.replace("{tb_endpoint_0}", fesql_config.tb_endpoint_0) |
| 239 | if "{tb_endpoint_1}" in sql: |
| 240 | sql = sql.replace("{tb_endpoint_1}", fesql_config.tb_endpoint_1) |
| 241 | if "{tb_endpoint_2}" in sql: |
| 242 | sql = sql.replace("{tb_endpoint_2}", fesql_config.tb_endpoint_2) |
| 243 | indexs = formatSqlReg.findall(sql) |
| 244 | for indexStr in indexs: |
| 245 | index = int(indexStr) |
| 246 | sql = sql.replace("{" + indexStr + "}",tableNames[index]) |
| 247 | return sql |
| 248 | |
| 249 | def createAndInsert(executor,dbName,inputs,requestMode:bool=False): |
| 250 | tableNames = [] |
no test coverage detected