zoukankan      html  css  js  c++  java
  • C# update join,delete join

    public static int UpdateJoin(DbFactory factory, string relationKey, string foreignKey, Dictionary<string, object> data, string condition, Joins mode, out string sql)
            {
                int count = data.Count;
                if (count == 0)
                {
                    throw new ArgumentException("data");
                }
                string table = relationKey.Substring(0, relationKey.IndexOf(SqlBuilder.JoinSymbol)), foreignTable = foreignKey.Substring(0, foreignKey.IndexOf(SqlBuilder.JoinSymbol));
                count *= 8 + Math.Max(table.Length, foreignTable.Length);
                StringBuilder sb = new StringBuilder(count);
                using (Dictionary<string, object>.Enumerator e = data.GetEnumerator())
                {
                    e.MoveNext();
                    sb.Append(e.Current.Key).Append("=").AppendValue(e.Current.Value);
                    while (e.MoveNext())
                    {
                        sb.Append(SqlBuilder.Separator).Append(e.Current.Key).Append("=").AppendValue(e.Current.Value);
                    }
                }
                switch (factory.ProviderName)
                {
                    case DbProvider.Sql:
                        sql = String.Concat("UPDATE [", table, "] SET ", sb.ToString(), " FROM [", table, "] ", mode.ToString(), " JOIN [", foreignTable, "] ON ", relationKey, "=", foreignKey, SqlBuilder.Space, condition);
                        break;
                    case DbProvider.OleDb:
                        sql = String.Concat("UPDATE [", table, "] ", mode.ToString(), " JOIN [", foreignTable, "] ON ", relationKey, "=", foreignKey, " SET ", sb.ToString(), SqlBuilder.Space, condition);
                        break;
                    default:
                        throw new NotSupportedException();
                }
                return DbBase.ExecuteNonQuery(factory, sql);
            }
    
            public static int DeleteJoin(DbFactory factory, string relationKey, string foreignKey, string condition, Joins mode, out string sql)
            {
                string table = relationKey.Substring(0, relationKey.IndexOf(SqlBuilder.JoinSymbol)), foreignTable = foreignKey.Substring(0, foreignKey.IndexOf(SqlBuilder.JoinSymbol));
                switch (factory.ProviderName)
                {
                    case DbProvider.Sql:
                        sql = String.Concat("DELETE FROM [", table, "] FROM [", table, "] ", mode.ToString(), " JOIN [", foreignTable, "] ON ", relationKey, "=", foreignKey, SqlBuilder.Space, condition);
                        break;
                    case DbProvider.OleDb:
                        sql = String.Concat("DELETE ", table, ".*,", foreignTable, ".* FROM [", table, "] ", mode.ToString(), " JOIN [", foreignTable, "] ON ", relationKey, "=", foreignKey, SqlBuilder.Space, condition);
                        break;
                    default:
                        throw new NotSupportedException();
                }
                return DbBase.ExecuteNonQuery(factory, sql);
            }
    
  • 相关阅读:
    kuryr环境搭建
    使用docker搭建kafka环境
    记一次解决curl https证书问题
    一篇精彩的洗地文
    个人知识管理利器wiz
    Markdown写作
    用Bottle开发web程序(二)
    用Bottle开发web程序(一)
    Magnum Kubernetes源码分析(二)
    DVWA(九):File Upload 全等级文件上传
  • 原文地址:https://www.cnblogs.com/Googler/p/1759172.html
Copyright © 2011-2022 走看看