(name:str,columns:list,inexs:list)
| 36 | return tableName |
| 37 | |
| 38 | def getCreateSql(name:str,columns:list,inexs:list): |
| 39 | time.sleep(1) |
| 40 | createSql = "create table "+name+"(" |
| 41 | for column in columns: |
| 42 | createSql+=column+"," |
| 43 | for index in inexs: |
| 44 | ss = index.split(":") |
| 45 | if len(ss)>=2: |
| 46 | keyStr = ss[1] |
| 47 | if("|" in ss[1]): |
| 48 | keyStr = ",".join(ss[1].split("|")) |
| 49 | if len(ss)==2: |
| 50 | createSql+="index(key=(%s))," % (keyStr) |
| 51 | elif len(ss)==3: |
| 52 | createSql+="index(key=(%s),ts=%s)," % (keyStr,ss[2]) |
| 53 | elif len(ss)==4: |
| 54 | createSql += "index(key=(%s),ts=%s,ttl=%s)," % (keyStr, ss[2],ss[3]) |
| 55 | elif len(ss)==5: |
| 56 | createSql += "index(key=(%s),ts=%s,ttl=%s,ttl_type=%s)," % (keyStr, ss[2], ss[3],ss[4]) |
| 57 | if createSql.endswith(","): |
| 58 | createSql = createSql[0:-1] |
| 59 | createSql+=");" |
| 60 | return createSql |
| 61 | |
| 62 | def getIndexByColumnName(schema,columnName): |
| 63 | if hasattr(schema, "GetColumnCnt"): |
no test coverage detected