|
9 | 9 | from data_designer.config.validator_params import CodeValidatorParams |
10 | 10 | from data_designer.engine.validators.sql import SQLValidator |
11 | 11 |
|
12 | | - |
13 | | -def test_valid_ansi_sql_code() -> None: |
14 | | - sql_validator = SQLValidator(CodeValidatorParams(code_lang=CodeLang.SQL_ANSI)) |
15 | | - code = "SELECT category, COUNT(*) as total_incidents FROM security_incidents_2 GROUP BY category;" |
| 12 | +VALID_SQL_BY_DIALECT = [ |
| 13 | + ( |
| 14 | + CodeLang.SQL_ANSI, |
| 15 | + "SELECT category, COUNT(*) AS total_incidents FROM security_incidents_2 GROUP BY category;", |
| 16 | + ), |
| 17 | + (CodeLang.SQL_SQLITE, "SELECT sqlite_version() AS version;"), |
| 18 | + (CodeLang.SQL_TSQL, "SELECT TOP 1 name FROM sys.objects;"), |
| 19 | + (CodeLang.SQL_BIGQUERY, "SELECT * EXCEPT(sensitive_column) FROM `project.dataset.table`;"), |
| 20 | + (CodeLang.SQL_MYSQL, "SELECT `name` FROM users LIMIT 1;"), |
| 21 | + (CodeLang.SQL_POSTGRES, "SELECT 1::int AS value;"), |
| 22 | +] |
| 23 | + |
| 24 | + |
| 25 | +@pytest.mark.parametrize(("code_lang", "code"), VALID_SQL_BY_DIALECT) |
| 26 | +def test_valid_sql_code_for_supported_dialects(code_lang: CodeLang, code: str) -> None: |
| 27 | + sql_validator = SQLValidator(CodeValidatorParams(code_lang=code_lang)) |
16 | 28 | result = sql_validator.run_validation([{"sql": code}]) |
17 | 29 | assert result.data[0].is_valid |
18 | 30 | assert result.data[0].error_messages == "" |
|
0 commit comments