(ds: CoreDatasource, conf: DatasourceConf)
| 5 | |
| 6 | |
| 7 | def get_version_sql(ds: CoreDatasource, conf: DatasourceConf): |
| 8 | if equals_ignore_case(ds.type, "mysql", "doris", "starrocks"): |
| 9 | return """ |
| 10 | SELECT VERSION() |
| 11 | """ |
| 12 | elif equals_ignore_case(ds.type, "sqlServer"): |
| 13 | return """ |
| 14 | select SERVERPROPERTY('ProductVersion') |
| 15 | """ |
| 16 | elif equals_ignore_case(ds.type, "pg", "kingbase", "excel"): |
| 17 | return """ |
| 18 | SELECT current_setting('server_version') |
| 19 | """ |
| 20 | elif equals_ignore_case(ds.type, "oracle"): |
| 21 | return """ |
| 22 | SELECT version FROM v$instance |
| 23 | """ |
| 24 | elif equals_ignore_case(ds.type, "ck"): |
| 25 | return """ |
| 26 | select version() |
| 27 | """ |
| 28 | elif equals_ignore_case(ds.type, "dm"): |
| 29 | return """ |
| 30 | SELECT * FROM v$version |
| 31 | """ |
| 32 | elif equals_ignore_case(ds.type, "redshift", "sqlite", "hive"): |
| 33 | return '' |
| 34 | |
| 35 | |
| 36 | def get_table_sql(ds: CoreDatasource, conf: DatasourceConf, db_version: str = ''): |
no test coverage detected