(type: str, conf: DatasourceConf)
| 109 | |
| 110 | |
| 111 | def get_origin_connect(type: str, conf: DatasourceConf): |
| 112 | extra_config_dict = get_extra_config(conf) |
| 113 | if equals_ignore_case(type, "sqlServer"): |
| 114 | # none or true, set tds_version = 7.0 |
| 115 | if conf.lowVersion is None or conf.lowVersion: |
| 116 | return pymssql.connect( |
| 117 | server=conf.host, |
| 118 | port=str(conf.port), |
| 119 | user=conf.username, |
| 120 | password=conf.password, |
| 121 | database=conf.database, |
| 122 | timeout=conf.timeout, |
| 123 | tds_version='7.0', # options: '4.2', '7.0', '8.0' ..., |
| 124 | **extra_config_dict |
| 125 | ) |
| 126 | else: |
| 127 | return pymssql.connect( |
| 128 | server=conf.host, |
| 129 | port=str(conf.port), |
| 130 | user=conf.username, |
| 131 | password=conf.password, |
| 132 | database=conf.database, |
| 133 | timeout=conf.timeout, |
| 134 | **extra_config_dict |
| 135 | ) |
| 136 | |
| 137 | |
| 138 | # use sqlalchemy |
no test coverage detected