[ElServer 리뷰] 엑셀 스키마를 그대로 테이블로 쓰는 C# ORM

[AttributeUsage(AttributeTargets.Property)]
public class ElPrimaryKeyAttribute : Attribute
{
}
…
[AttributeUsage(AttributeTargets.Property)]
public class ElMaxLengthAttribute : Attribute
{
    public int Value { get; private set; }

    public ElMaxLengthAttribute(int length)
    {
        Value = length;
    }
}

Column c = new Column(pi.Name, pi.PropertyType);

if (pi.GetCustomAttribute(typeof(ElPrimaryKeyAttribute)) != null)
{
    c.IsPrimaryKey = true;
    c.IsIndex = true;
    has_primary_key = true;
    ElILogger.Get().Log(pi.Name + " IsPrimaryKey");
}

if (c.IsPrimaryKey && pi.GetCustomAttribute(typeof(ElAutoIncrementAttribute)) != null)
{
    c.IsAutoIncrement = true;
    ElILogger.Get().Log(pi.Name + " IsAutoIncrement");
}

if (pi.GetCustomAttribute(typeof(ElIndexedAttribute)) != null)
{
    c.IsIndex = true;
    ElILogger.Get().Log(pi.Name + " IsIndex");
}

public abstract class ElIDatabaseExecutor
{
    public abstract int ExecuteNonQuery(string sql);

    public abstract List<TableClass> ExecuteQuery<TableClass>(string sql);

    public abstract bool IsSupportGeneric();

    public abstract bool IsSupportDeclareAutoIncrement();

    public abstract bool IsSupportModify();

    public abstract string GetAutoIncrementKeyword();
…
    public abstract void BeginTransaction();

    public abstract void Commit();

    public abstract void Rollback();

DbConnection conn = ElConnectionPool.Get().GetConnection();

try
{
    if (receive_packet.Type == -1)
    {
        ElPacket_GroupRequest typed_pk = (ElPacket_GroupRequest)receive_packet;
        ElPacket packet;
        for (int i = 0; i < typed_pk.PacketList.Count; ++i)
        {
            packet = typed_pk.PacketList[i];
            if (MessageTable.ContainsKey((int)packet.Type))
            {
                MessageTable[(int)packet.Type](packet, sender, conn);
            }
        }
    }
    else if (receive_packet.Type == -2)
    {
        ElPacket_Ping_Response response = new ElPacket_Ping_Response();
        SendPacketTo(sender, response);
    }
    else if (MessageTable.ContainsKey((int)receive_packet.Type))
    {
        MessageTable[(int)receive_packet.Type](receive_packet, sender, conn);
    }

ElTableSchema? ts = ElSchemaFactory.GetTableSchema(tableName);

if (ts != null)
{
    string where = MakeWhereConditionSQL(ts, whereConditions);
    string sql = string.Format("SELECT " + wildcard + " FROM {0} WHERE {1}", tableName, where);

    if (where.Trim().Equals(""))
    {
        sql = sql.Replace(" WHERE ", "");
    }

    if (!string.IsNullOrEmpty(lastOption))
    {
        sql += " " + lastOption + ";";
    }
    else
    {
        sql += ";";
    }

foreach (var fieldInfo in fields)
{
    foreach (DataColumn dc in dt.Columns)
    {
        // Matching the columns with fields
        if (fieldInfo.Name == dc.ColumnName)
        {
            // Get the value from the datatable cell
            object value = dr[dc.ColumnName];

            if (value != DBNull.Value)
            {
                if (value.GetType() == typeof(DateTime))
                {
                    fieldInfo.SetValue(ob, value.ToString());
                }
                else
                {
                    // Set the value into the object
                    fieldInfo.SetValue(ob, value);
                }
            }

            break;
        }
    }
}

ob.OnEndInit(currentExecutor);

Column? c = ts.GetColumn(search_column);

if (c != null)
{
    if (!keyword.Contains('\'') && c.ColumnType == typeof(string))
    {
        keyword = "'" + keyword + "'";
    }

    if (!c.IsIndex && !c.IsPrimaryKey)
    {
        ElILogger.Get().MessageLog("Column [" + c.ColumnName + "] is not index column. This will make slower.");
    }

    string condition = search_column + op + keyword;

    if (count > 0)
    {
        where += " AND ";
    }

    where += condition;

    count++;
}

protected void OnPropertyChanged(string propertyName, object newValue)
{
    if (!bLoaded) return;
    if (bStopUpdateDB)
    {
        changes.Add(new ChangeEntry(propertyName, newValue));
        return;
    }

    if (parentExecutor == null)
    {
        throw new Exception("DB Executor is null. Call ElDatabase.SetDatabaseExecutor(ElIDatabaseExecutor) to set DB Executor.");
    }

…
    parentExecutor.ExecuteNonQuery(string.Format("UPDATE {0} SET {1}={2} WHERE {3}", GetClassName(), propertyName, newValueStr, GetPrimaryKeyWhereStatement()));
}

DataColumn? dtc = FindDataColumn(c.ColumnName, ref dataColumns);

if (dtc == null)
{
    column_sql += "ADD COLUMN ";
    MakeColumnSql(c, ref column_sql, executor);
    do_modify = true;
}
else
{
    if (!executor.IsEqualTypes(c.ColumnType, dtc.DataType)
        || c.AllowDBNull != dtc.AllowDBNull
         || c.IsPrimaryKey != IsPrimaryKey(dtc)
         || c.IsAutoIncrement != dtc.AutoIncrement
         || c.DefaultValue != dtc.DefaultValue.ToString().Replace("'", "")
         || (dtc.MaxLength >= 0 && c.MaxLength >= 0 && c.MaxLength != dtc.MaxLength))
    {
        column_sql += "MODIFY COLUMN ";
        MakeColumnSql(c, ref column_sql, executor);
        do_modify = true;
    }