59 lines
2.1 KiB
C#
59 lines
2.1 KiB
C#
|
using Elsa.Common.Entities;
|
||
|
|
using Elsa.Dapper.Contracts;
|
||
|
|
|
||
|
|
namespace Elsa.Dapper.Abstractions;
|
||
|
|
|
||
|
|
/// <summary>
|
||
|
|
/// Provides a base implementation of <see cref="ISqlDialect"/>, where the dialect defaults to SQLite.
|
||
|
|
/// </summary>
|
||
|
|
public abstract class SqlDialectBase : ISqlDialect
|
||
|
|
{
|
||
|
|
/// <inheritdoc />
|
||
|
|
public virtual string From(string table) => From(table, "*");
|
||
|
|
|
||
|
|
/// <inheritdoc />
|
||
|
|
public virtual string From(string table, params string[] fields)
|
||
|
|
{
|
||
|
|
var fieldList = string.Join(", ", fields);
|
||
|
|
return $"select {fieldList} from {table} where 1=1";
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <inheritdoc />
|
||
|
|
public string Delete(string table) => $"delete from {table} where 1=1";
|
||
|
|
|
||
|
|
/// <inheritdoc />
|
||
|
|
public string Count(string table) => $"select COUNT(*) from {table} where 1=1";
|
||
|
|
|
||
|
|
/// <inheritdoc />
|
||
|
|
public virtual string And(string field) => $"and {field} = @{field}";
|
||
|
|
|
||
|
|
/// <inheritdoc />
|
||
|
|
public virtual string And(string field, string[] fieldParamNames)
|
||
|
|
{
|
||
|
|
return $"and {field} in ({string.Join(", ", fieldParamNames)})";
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <inheritdoc />
|
||
|
|
public virtual string OrderBy(string field, OrderDirection direction)
|
||
|
|
{
|
||
|
|
var directionString = direction == OrderDirection.Ascending ? "asc" : "desc";
|
||
|
|
return $"order by {field} {directionString}";
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <inheritdoc />
|
||
|
|
public virtual string Skip(int count) => $"OFFSET {count}";
|
||
|
|
|
||
|
|
/// <inheritdoc />
|
||
|
|
public virtual string Take(int count) => $"LIMIT {count}";
|
||
|
|
|
||
|
|
/// <inheritdoc />
|
||
|
|
public virtual string Upsert(string table, string primaryKeyField, string[] fields)
|
||
|
|
{
|
||
|
|
var fieldList = string.Join(", ", fields);
|
||
|
|
var fieldParamNames = fields.Select(x => $"@{x}");
|
||
|
|
var fieldParamList = string.Join(", ", fieldParamNames);
|
||
|
|
//var updateList = string.Join(", ", fields.Select(x => $"{x} = @{x}"));
|
||
|
|
//return $"insert into {table} ({fieldList}) values ({fieldParamList}) on conflict(id) do update set {updateList}";
|
||
|
|
return $"INSERT OR REPLACE INTO {table} ({primaryKeyField}, {fieldList}) VALUES (@{primaryKeyField}, {fieldParamList});";
|
||
|
|
}
|
||
|
|
}
|