Commit cc02a9a2 by 李承祥

抽取根据数据库类型添加连接

parent 6b9fe927
...@@ -473,7 +473,7 @@ private List<ExtractDto> QueryDatabase(List<sys_hospitalconfig> hospitalConfigLi ...@@ -473,7 +473,7 @@ private List<ExtractDto> QueryDatabase(List<sys_hospitalconfig> hospitalConfigLi
var config = hospitalConfigList.FirstOrDefault(t => t.Type == extract.SourceType); var config = hospitalConfigList.FirstOrDefault(t => t.Type == extract.SourceType);
string executeScript = extract.ExecuteScript; string executeScript = extract.ExecuteScript;
var parameters = GetParameters(allot); var parameters = GetParameters(allot);
using (var connection = ConnectionBuilder.Create(DatabaseType.SqlServer, config.DbSource, config.DbName, config.DbUser, config.DbPassword)) using (var connection = ConnectionBuilder.Create((DatabaseType)config.DataBaseType, config.DbSource, config.DbName, config.DbUser, config.DbPassword))
{ {
foreach (var item in parameters) foreach (var item in parameters)
{ {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment