| 159 | } |
| 160 | |
| 161 | func getStatementWithResultLimit(statement string, limit int) string { |
| 162 | stmt, err := getStatementWithResultLimitInline(statement, limit) |
| 163 | if err != nil { |
| 164 | slog.Error("fail to add limit clause", slog.String("statement", statement), log.BBError(err)) |
| 165 | return fmt.Sprintf("WITH result AS (%s) SELECT TOP %d * FROM result;", util.TrimStatement(statement), limit) |
| 166 | } |
| 167 | return stmt |
| 168 | } |
| 169 | |
| 170 | func getStatementWithResultLimitInline(singleStatement string, limitCount int) (string, error) { |
| 171 | return omnimssql.StatementWithResultLimit(singleStatement, limitCount) |