2019-05-15 14:56:09 +00:00
|
|
|
/*
|
|
|
|
*
|
|
|
|
* (c) Copyright Ascensio System Limited 2010-2018
|
|
|
|
*
|
|
|
|
* This program is freeware. You can redistribute it and/or modify it under the terms of the GNU
|
|
|
|
* General Public License (GPL) version 3 as published by the Free Software Foundation (https://www.gnu.org/copyleft/gpl.html).
|
|
|
|
* In accordance with Section 7(a) of the GNU GPL its Section 15 shall be amended to the effect that
|
|
|
|
* Ascensio System SIA expressly excludes the warranty of non-infringement of any third-party rights.
|
|
|
|
*
|
|
|
|
* THIS PROGRAM IS DISTRIBUTED WITHOUT ANY WARRANTY; WITHOUT EVEN THE IMPLIED WARRANTY OF MERCHANTABILITY OR
|
|
|
|
* FITNESS FOR A PARTICULAR PURPOSE. For more details, see GNU GPL at https://www.gnu.org/copyleft/gpl.html
|
|
|
|
*
|
|
|
|
* You can contact Ascensio System SIA by email at sales@onlyoffice.com
|
|
|
|
*
|
|
|
|
* The interactive user interfaces in modified source and object code versions of ONLYOFFICE must display
|
|
|
|
* Appropriate Legal Notices, as required under Section 5 of the GNU GPL version 3.
|
|
|
|
*
|
|
|
|
* Pursuant to Section 7 § 3(b) of the GNU GPL you must retain the original ONLYOFFICE logo which contains
|
|
|
|
* relevant author attributions when distributing the software. If the display of the logo in its graphic
|
|
|
|
* form is not reasonably feasible for technical reasons, you must include the words "Powered by ONLYOFFICE"
|
|
|
|
* in every copy of the program you distribute.
|
|
|
|
* Pursuant to Section 7 § 3(e) we decline to grant you any rights under trademark law for use of our trademarks.
|
|
|
|
*
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
|
|
using System.Collections.Generic;
|
|
|
|
using System.Diagnostics;
|
2019-08-15 12:04:42 +00:00
|
|
|
using System.Text;
|
2019-05-15 14:56:09 +00:00
|
|
|
using ASC.Common.Data.Sql.Expressions;
|
|
|
|
|
|
|
|
namespace ASC.Common.Data.Sql
|
|
|
|
{
|
|
|
|
[DebuggerTypeProxy(typeof(SqlDebugView))]
|
|
|
|
public class SqlUpdate : ISqlInstruction
|
|
|
|
{
|
|
|
|
private readonly List<string> expressions = new List<string>();
|
|
|
|
private readonly List<JoinInfo> joins = new List<JoinInfo>();
|
|
|
|
private readonly Dictionary<string, object> sets = new Dictionary<string, object>();
|
|
|
|
private readonly SqlIdentifier table;
|
|
|
|
private Exp where = Exp.Empty;
|
|
|
|
|
|
|
|
public SqlUpdate(string table)
|
|
|
|
{
|
|
|
|
this.table = (SqlIdentifier)table;
|
|
|
|
}
|
|
|
|
|
|
|
|
#region ISqlInstruction Members
|
|
|
|
|
|
|
|
public string ToString(ISqlDialect dialect)
|
|
|
|
{
|
|
|
|
var sql = new StringBuilder();
|
|
|
|
|
|
|
|
if (0 < joins.Count)
|
|
|
|
{
|
|
|
|
sql.AppendFormat("update {0}", table.ToString(dialect));
|
|
|
|
|
|
|
|
foreach (var join in joins)
|
|
|
|
{
|
|
|
|
if (@join.JoinType == SqlJoin.Inner) sql.Append(" inner join ");
|
|
|
|
if (@join.JoinType == SqlJoin.LeftOuter) sql.Append(" left outer join ");
|
|
|
|
if (@join.JoinType == SqlJoin.RightOuter) sql.Append(" right outer join ");
|
|
|
|
sql.AppendFormat("{0} on {1}", @join.With.ToString(dialect), @join.On.ToString(dialect));
|
|
|
|
}
|
|
|
|
|
|
|
|
sql.Append(" set ");
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
sql.AppendFormat("update {0} set ", table.ToString(dialect));
|
|
|
|
}
|
|
|
|
|
|
|
|
foreach (var set in sets)
|
|
|
|
{
|
|
|
|
sql.AppendFormat("{0} = {1}, ", set.Key, set.Value is ISqlInstruction ? ((ISqlInstruction)set.Value).ToString(dialect) : "?");
|
|
|
|
}
|
|
|
|
expressions.ForEach(expression => sql.AppendFormat("{0}, ", expression));
|
|
|
|
sql.Remove(sql.Length - 2, 2);
|
|
|
|
if (where != Exp.Empty) sql.AppendFormat(" where {0}", where.ToString(dialect));
|
|
|
|
return sql.ToString();
|
|
|
|
}
|
|
|
|
|
|
|
|
public object[] GetParameters()
|
|
|
|
{
|
|
|
|
var parameters = new List<object>();
|
|
|
|
foreach (var join in joins)
|
|
|
|
{
|
|
|
|
parameters.AddRange(@join.With.GetParameters());
|
|
|
|
parameters.AddRange(@join.On.GetParameters());
|
|
|
|
}
|
|
|
|
|
2019-08-15 13:03:57 +00:00
|
|
|
foreach (var parameter in sets.Values)
|
2019-05-15 14:56:09 +00:00
|
|
|
{
|
|
|
|
if (parameter is ISqlInstruction)
|
|
|
|
{
|
|
|
|
parameters.AddRange(((ISqlInstruction)parameter).GetParameters());
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
|
|
|
parameters.Add(parameter);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (where != Exp.Empty) parameters.AddRange(where.GetParameters());
|
|
|
|
return parameters.ToArray();
|
|
|
|
}
|
|
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
|
|
private SqlUpdate Join(SqlJoin join, ISqlInstruction instruction, Exp on)
|
|
|
|
{
|
|
|
|
joins.Add(new JoinInfo(join, instruction, on));
|
|
|
|
return this;
|
|
|
|
}
|
|
|
|
|
|
|
|
public SqlUpdate InnerJoin(string tableName, Exp on)
|
|
|
|
{
|
|
|
|
return Join(SqlJoin.Inner, new SqlIdentifier(tableName), on);
|
|
|
|
}
|
|
|
|
|
|
|
|
public SqlUpdate LeftOuterJoin(string tableName, Exp on)
|
|
|
|
{
|
|
|
|
return Join(SqlJoin.LeftOuter, new SqlIdentifier(tableName), on);
|
|
|
|
}
|
|
|
|
|
|
|
|
public SqlUpdate RightOuterJoin(string tableName, Exp on)
|
|
|
|
{
|
|
|
|
return Join(SqlJoin.RightOuter, new SqlIdentifier(tableName), on);
|
|
|
|
}
|
|
|
|
|
|
|
|
public SqlUpdate Set(string expression)
|
|
|
|
{
|
|
|
|
expressions.Add(expression);
|
|
|
|
return this;
|
|
|
|
}
|
|
|
|
|
|
|
|
public SqlUpdate Set(string column, object value)
|
|
|
|
{
|
|
|
|
sets[column] = value is SqlQuery ? new AsExp((SqlQuery)value) : value;
|
|
|
|
return this;
|
|
|
|
}
|
|
|
|
|
|
|
|
public SqlUpdate Where(Exp where)
|
|
|
|
{
|
|
|
|
this.where = this.where & where;
|
|
|
|
return this;
|
|
|
|
}
|
|
|
|
|
|
|
|
public SqlUpdate Where(string column, object value)
|
|
|
|
{
|
|
|
|
return Where(Exp.Eq(column, value));
|
|
|
|
}
|
|
|
|
|
|
|
|
public override string ToString()
|
|
|
|
{
|
|
|
|
return ToString(SqlDialect.Default);
|
|
|
|
}
|
|
|
|
|
|
|
|
private class JoinInfo
|
|
|
|
{
|
|
|
|
public SqlJoin JoinType { get; private set; }
|
|
|
|
public Exp On { get; private set; }
|
|
|
|
public ISqlInstruction With { get; private set; }
|
|
|
|
|
|
|
|
public JoinInfo(SqlJoin joinType, ISqlInstruction with, Exp on)
|
|
|
|
{
|
|
|
|
With = with;
|
|
|
|
JoinType = joinType;
|
|
|
|
On = on;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
private enum SqlJoin
|
|
|
|
{
|
|
|
|
LeftOuter,
|
|
|
|
RightOuter,
|
|
|
|
Inner
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|