Merge pull request #1098 from yuguoqiang/master
fix #1097 SqlDriver: Database type mssql is not supported
This commit is contained in:
commit
21e92f46a1
|
|
@ -33,7 +33,7 @@ public class ExecuteQueryFn : IFunctionCallback
|
||||||
var results = dbType.ToLower() switch
|
var results = dbType.ToLower() switch
|
||||||
{
|
{
|
||||||
"mysql" => RunQueryInMySql(args.SqlStatements),
|
"mysql" => RunQueryInMySql(args.SqlStatements),
|
||||||
"sqlserver" => RunQueryInSqlServer(args.SqlStatements),
|
"sqlserver" or "mssql" => RunQueryInSqlServer(args.SqlStatements),
|
||||||
"redshift" => RunQueryInRedshift(args.SqlStatements),
|
"redshift" => RunQueryInRedshift(args.SqlStatements),
|
||||||
_ => throw new NotImplementedException($"Database type {dbType} is not supported.")
|
_ => throw new NotImplementedException($"Database type {dbType} is not supported.")
|
||||||
};
|
};
|
||||||
|
|
|
||||||
|
|
@ -37,7 +37,7 @@ public class GetTableDefinitionFn : IFunctionCallback
|
||||||
var tableDdls = dbType switch
|
var tableDdls = dbType switch
|
||||||
{
|
{
|
||||||
"mysql" => GetDdlFromMySql(tables),
|
"mysql" => GetDdlFromMySql(tables),
|
||||||
"sqlserver" => GetDdlFromSqlServer(tables),
|
"sqlserver" or "mssql" => GetDdlFromSqlServer(tables),
|
||||||
"redshift" => GetDdlFromRedshift(tables),
|
"redshift" => GetDdlFromRedshift(tables),
|
||||||
_ => throw new NotImplementedException($"Database type {dbType} is not supported.")
|
_ => throw new NotImplementedException($"Database type {dbType} is not supported.")
|
||||||
};
|
};
|
||||||
|
|
|
||||||
|
|
@ -32,7 +32,7 @@ public class SqlSelect : IFunctionCallback
|
||||||
var result = dbType switch
|
var result = dbType switch
|
||||||
{
|
{
|
||||||
"mysql" => RunQueryInMySql(args),
|
"mysql" => RunQueryInMySql(args),
|
||||||
"sqlserver" => RunQueryInSqlServer(args),
|
"sqlserver" or "mssql" => RunQueryInSqlServer(args),
|
||||||
"redshift" => RunQueryInRedshift(args),
|
"redshift" => RunQueryInRedshift(args),
|
||||||
_ => throw new NotImplementedException($"Database type {dbType} is not supported.")
|
_ => throw new NotImplementedException($"Database type {dbType} is not supported.")
|
||||||
};
|
};
|
||||||
|
|
|
||||||
|
|
@ -34,7 +34,7 @@ public class SqlValidateFn : IFunctionCallback
|
||||||
var validateSql = dbType.ToLower() switch
|
var validateSql = dbType.ToLower() switch
|
||||||
{
|
{
|
||||||
"mysql" => $"EXPLAIN\r\n{sql.Replace("SET ", "-- SET ", StringComparison.InvariantCultureIgnoreCase).Replace(";", "; EXPLAIN ").TrimEnd("EXPLAIN ".ToCharArray())}",
|
"mysql" => $"EXPLAIN\r\n{sql.Replace("SET ", "-- SET ", StringComparison.InvariantCultureIgnoreCase).Replace(";", "; EXPLAIN ").TrimEnd("EXPLAIN ".ToCharArray())}",
|
||||||
"sqlserver" => $"SET PARSEONLY ON;\r\n{sql}\r\nSET PARSEONLY OFF;",
|
"sqlserver" or "mssql" => $"SET PARSEONLY ON;\r\n{sql}\r\nSET PARSEONLY OFF;",
|
||||||
"redshift" => $"explain\r\n{sql}",
|
"redshift" => $"explain\r\n{sql}",
|
||||||
_ => throw new NotImplementedException($"Database type {dbType} is not supported.")
|
_ => throw new NotImplementedException($"Database type {dbType} is not supported.")
|
||||||
};
|
};
|
||||||
|
|
|
||||||
|
|
@ -31,7 +31,7 @@ public class GetTableDefinitionFn : IFunctionCallback
|
||||||
var tableDdls = dbType switch
|
var tableDdls = dbType switch
|
||||||
{
|
{
|
||||||
"mysql" => GetDdlFromMySql(tables),
|
"mysql" => GetDdlFromMySql(tables),
|
||||||
"sqlserver" => GetDdlFromSqlServer(tables),
|
"sqlserver" or "mssql" => GetDdlFromSqlServer(tables),
|
||||||
"redshift" => GetDdlFromRedshift(tables,schema),
|
"redshift" => GetDdlFromRedshift(tables,schema),
|
||||||
_ => throw new NotImplementedException($"Database type {dbType} is not supported.")
|
_ => throw new NotImplementedException($"Database type {dbType} is not supported.")
|
||||||
};
|
};
|
||||||
|
|
|
||||||
|
|
@ -30,7 +30,7 @@ public class SqlSelect : IFunctionCallback
|
||||||
var result = dbType switch
|
var result = dbType switch
|
||||||
{
|
{
|
||||||
"mysql" => RunQueryInMySql(args),
|
"mysql" => RunQueryInMySql(args),
|
||||||
"sqlserver" => RunQueryInSqlServer(args),
|
"sqlserver" or "mssql" => RunQueryInSqlServer(args),
|
||||||
"redshift" => RunQueryInRedshift(args),
|
"redshift" => RunQueryInRedshift(args),
|
||||||
_ => throw new NotImplementedException($"Database type {dbType} is not supported.")
|
_ => throw new NotImplementedException($"Database type {dbType} is not supported.")
|
||||||
};
|
};
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue