1
yhj
2024-07-24 5e5d945e91568b973faa27d8ab0bcef99fc4a6c5
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
#region
 
using System;
using System.Data;
using CSFrameworkV5.Core;
using CSFrameworkV5.Core.CodeGenerator;
using CSFrameworkV5.Interfaces;
using CSFrameworkV5.Models;
 
#endregion
 
/*===================================================================
 *   程序说明: DataFieldConfig的数据访问层源码
 *   作者资料: 楚楚.C/S框架网
 *   创建日期: 2014/06/07 10:20:48
 *   最后修改: 2014/06/07 10:20:48
 *
 *   注: 本代码由代码生成器(Code Generator)自动生成
 *   (此源码文件请放置在DataAccess模块)
 *   版权所有 copyright 2006~2014, C/S框架网 http://www.csframework.com
 *===================================================================*/
 
namespace CSFrameworkV5.DataAccess
{
    /// <summary>
    ///     DAL数据层:dalDataFieldConfig
    /// </summary>
    [DefaultORM_UpdateMode(typeof(sys_DataFieldConfig), true)]
    public class dalDataFieldConfig : dalBaseDataDict, IBridge_DataFieldConfig
    {
        /// <summary>
        ///     构造器
        /// </summary>
        /// <param name="loginer">当前登录用户</param>
        public dalDataFieldConfig(Loginer loginer)
            : base(loginer)
        {
            _KeyName = sys_DataFieldConfig.__KeyName; //主键字段
            _TableName = sys_DataFieldConfig.__TableName; //表名
            _ModelType = typeof(sys_DataFieldConfig); //指定ORM模型
        }
 
        public DataTable GetConfig(string configName)
        {
            var sql =
                $"SELECT * FROM sys_DataFieldConfig WHERE ConfigName={_Database.ParamSymboName}ConfigName;";
            var cmd = _Database.CreateCommand(sql);
            cmd.AddParam("ConfigName", configName);
            return _Database.GetTable(cmd.Command,
                sys_DataFieldConfig.__TableName);
        }
 
        public DataTable GetConfig(string account, string configName)
        {
            var sql =
                $"SELECT * FROM sys_DataFieldConfig WHERE ConfigName={_Database.ParamSymboName}ConfigName AND UserName={_Database.ParamSymboName}UserName;";
            var cmd = _Database.CreateCommand(sql);
            cmd.AddParam("ConfigName", configName);
            cmd.AddParam("UserName", account);
            return _Database.GetTable(cmd.Command,
                sys_DataFieldConfig.__TableName);
        }
 
        /// <summary>
        ///     根据表名获取该表的SQL命令生成器
        /// </summary>
        /// <param name="tableName">表名</param>
        /// <returns></returns>
        protected override IGenerateSqlCommand CreateSqlGenerator(
            DataTable table)
        {
            Type ORM = null;
            if (table.TableName == sys_DataFieldConfig.__TableName)
                ORM = typeof(sys_DataFieldConfig); //指定表与ORM模型的对应关系
 
            if (ORM == null) throw new Exception(table.TableName + "表没有ORM模型!");
 
            return new GenerateSqlCmdByTableFields(ORM, table,
                GeneratorFactory);
        }
 
        public override bool Update(DataSet data)
        {
            _UserManualControlTrans = true;
 
            try
            {
                BeginTransaction();
 
                //保存资料前清空旧数据
                var R = data.Tables[0].Rows[0];
 
                var sql =
                    $"DELETE FROM sys_DataFieldConfig WHERE ConfigName={_Database.ParamSymboName}ConfigName AND UserName={_Database.ParamSymboName}UserName;";
                var cmd = _Database.CreateCommand(sql);
                cmd.AddParam("ConfigName", R[sys_DataFieldConfig.ConfigName]);
                cmd.AddParam("UserName", R[sys_DataFieldConfig.UserName]);
 
                _Database.ExecuteTrans(_CurrentTrans, cmd.Command);
 
                var ret = base.Update(data);
 
                CommitTransaction();
                return ret;
            }
            catch
            {
                RollbackTransaction();
                return false;
            }
        }
    } //public class
} //namespace