Microsoft MVP성태의 닷넷 이야기
ef core, FromSqlRaw 맵핑 질문입니다. [링크 복사], [링크+제목 복사],
조회: 2184
글쓴 사람
victor (jys923 at gmail.com)
홈페이지
첨부 파일
 

.FromSqlRaw 의 결과가 동적입니다.

sn : result1 : result2 : result3 : result4 : result5 :

result1 결과가 몇개가 될지 모릅니다.

그래서 맵핑하는 클래스에 string sn과 List<int> result 를 만들었는데 맵핑이 잘안되네요.


int numberOfResults = 5; // 생성할 서브쿼리 개수

StringBuilder sqlBuilder = new StringBuilder();
for (int i = 1; i <= numberOfResults; i++)
{
    sqlBuilder.AppendLine($"(SELECT Result FROM Inspects WHERE ProbeSNId = main.ProbeSNId AND InspectTypeId = {i} AND DataFlag = 1) AS {i},");
}

// 마지막 줄에는 쉼표를 제거
sqlBuilder.Remove(sqlBuilder.Length - 3, 1);

string sql = @"
            SELECT CONCAT(pt.Code, pst.DateTime, LPAD(pst.PcNo, 3, '0'), LPAD(ps.ProbeSeqNo,5,'0')) AS ProbeSN,
                   {sqlBuilder}
            FROM (SELECT DISTINCT ProbeSNId FROM Inspects) AS main
            JOIN ProbeSNs ps ON main.ProbeSNId = ps.Id
            JOIN ProbeSNTypes pst ON ps.ProbeSNTypeId = pst.Id
            JOIN ProbeTypes pt ON ps.ProbeTypeId = pt.Id";

List<ProbeSNView> probeSNViews = db.ProbeSNViews
    .FromSqlRaw(sql)
    .AsEnumerable()
    .Select(x => new ProbeSNView
    {
        ProbeSN = x.ProbeSN,
        Result = GetDynamicResults(x).ToList(),
    })
    .ToList();

private static List<int> GetDynamicResults(dynamic x)
{
    var results = new List<int>();

    for (int i = 1; i <= 5; i++)
    {
        var result = x[i] as int?;

        if (result.HasValue)
        {
            results.Add(result.Value);
        }
    }

    return results;
}


//[NotMapped]
public class ProbeSNView
{
    //[Key]
    public required string ProbeSN { get; set; }

    public IEnumerable<int>? Result { get; set; }
}

이렇게 해봤습니다.

어떻게 맵핑 하면 좋을까요?

https://github.com/jys923/ProcessAutomation.git








[최초 등록일: ]
[최종 수정일: 2/22/2024]


비밀번호

댓글 작성자
 



2024-02-22 04시29분
일단, 위의 방식대로 하면 예외(Exception) 없이 잘 동작했나요? 만약 예외 없이 코드가 잘 수행된다면, 그 코드까지 테스트한 것을 github에 체크인해 주세요. 그리고 디버그 상태에서 GetDynamicResults 메서드에 BP를 걸고 x의 값을 Watch 창으로 한번 확인해 보세요.
정성태
2024-02-23 08시35분
답변 갑사합니다.
예외(Exception)가 났습니다.

그래서 방식을 바꿨습니다.

바꾼 방식 github에 체크인 했습니다.

#elif SELECT_SQL_DYNAMIC
            #region select sql dynamic 18s
            // SQL 쿼리 문자열을 생성
            StringBuilder sqlBuilder = new StringBuilder();
            for (int i = 1; i <= numberOfResults; i++)
            {
                sqlBuilder.AppendLine($"(SELECT Result FROM Inspects WHERE ProbeSNId = main.ProbeSNId AND InspectTypeId = {i} AND DataFlag = 1) AS Result{i},");
            }
            // 마지막 줄에는 쉼표를 제거
            sqlBuilder.Remove(sqlBuilder.Length - 3, 1);

            string sql = $@"
            SELECT CONCAT(pt.Code, pst.DateTime, LPAD(pst.PcNo, 3, '0'), LPAD(ps.ProbeSeqNo,5,'0')) AS ProbeSN,
                   {sqlBuilder}
                FROM (SELECT DISTINCT ProbeSNId FROM Inspects) AS main
                JOIN ProbeSNs ps ON main.ProbeSNId = ps.Id
                JOIN ProbeSNTypes pst ON ps.ProbeSNTypeId = pst.Id
                JOIN ProbeTypes pt ON ps.ProbeTypeId = pt.Id";

            List<ProbeSNView> probeSNViews = new List<ProbeSNView>();

            // 데이터베이스 연결 및 쿼리 실행
            using (var command = db.Database.GetDbConnection().CreateCommand())
            {
                command.CommandText = sql;
                db.Database.OpenConnection();
                using (var result = command.ExecuteReader())
                {
                    while (result.Read())
                    {
                        ProbeSNView probeSNView = new ProbeSNView
                        {
                            ProbeSN = result.GetString(0), // 첫 번째 컬럼은 ProbeSN
                            Result = new List<int>()
                        };
                        for (int i = 1; i <= numberOfResults; i++)
                        {
                            // Result1, Result2, ... 컬럼은 1부터 시작
                            int? value = result.IsDBNull(i) ? null : (int?)result.GetInt32(i);
                            probeSNView.Result.Add(value ?? 0); // null일 경우 0으로 대체
                        }
                        probeSNViews.Add(probeSNView);
                    }
                }
            }

            /*foreach (var item in probeSNViews)
            {
                Console.Write(item.ProbeSN + " ");
                foreach (var result in item.Result)
                {
                    Console.Write(result + ": ");
                }
                Console.WriteLine("");
            }*/
            Console.WriteLine("probeSNViews.Count : " + probeSNViews.Count());
            #endregion
#endif

그런데 기존에 데이터 형이 정해 졌던 걸로 바로 맵핑 했을떄는 10만건 기준 1초였는데 8초가 걸리네요.

성능을 개선 시킬 좋은 방법 없을까요?
victor
2024-02-23 08시48분
SELECT_LINQ

SELECT_SQL

같은 쿼리인데 linq와 sql 속도차이가 20초 정도 납니다.

linq가 느립니다.

ms에선 linq를 추천 하는것 같은데 성능차가 너무 커서요

제가 뭔가 잘못한것 같아습니다. 검토 부탁드려도 될까요?
victor
2024-02-23 11시53분
예제에서 SELECT_SQL도 내부적으로는 SqlCommand/SqlDataRader를 사용할 뿐이어서 기본적인 처리는 SELECT_SQL_DYNAMIC과 같습니다.

단지, 2개의 예제가 다른 것은 SELECT_SQL의 경우 필드가 정해져 있는 반면, SELECT_SQL_DYNAMIC은 가변적이라는 정도인데요, 일단 테스트를 위해 SELECT_SQL_DYNAMIC 코드도 다음과 같은 식으로 바꿔보세요.

while (result.Read())
{
    ProbeView probeView = new ProbeView
    {
        ProbeSN = result.GetString(0),
        Result1 = result.GetInt32(1),
        Result2 = result.GetInt32(2),
        Result3 = result.GetInt32(3),
        Result4 = result.GetInt32(4),
        Result5 = result.GetInt32(5),
    };
    probeViews.Add(probeView);
}

만약 저 차이라면 방법이 없습니다.

혹은, 만약 가변 필드가 몇 개 안 된다면 고정 타입으로 ProbeViewResult1, ProbeViewResult2, ProbeViewResult3,... 등의 타입을 가져갈 수밖에 없습니다.
정성태

... 31  32  33  34  35  36  37  38  39  [40]  41  42  43  44  45  ...
NoWriterDateCnt.TitleFile(s)
4854heyh...7/6/20179913
4853heyh...7/5/201710004성태님이 작성한대로 해봤습니다. [1]파일 다운로드1
4852김레오7/4/201712130서드파티 dll 디버깅에 대해 질문드립니다. [2]
4851김현준7/3/201711222Datagridview VirtualMode 시 GC가 계속 호출되는 현상이 이해가 안갑니다. [2]
4850heyh...7/3/201710942성태님 밑에 질문드렸던 오류입니다. [1]파일 다운로드1
4849포플러7/2/201729694C#으로 만든 프로그램이 어느 순간 속도가 느려지거나 멈춤현상이 있습니다. [4]
4848윤진영7/2/201712626Microsoft Visual C++ 6.0 무설치 관련 [1]
4847heyh...6/30/201710614아무리 고민해도 답이 안나와서.. 질문 드립니다 [1]
4846heyh...6/28/201710668Clickonce에서 Clickonce로 변수 전달 [1]
4845heyh...6/26/201710254vb.net 에서 manifest 제거 방법 [1]파일 다운로드1
4844san6/21/20179733part3 pdf파일로 보는데 눈아퍼요.... 활자로 보고싶어요 [2]
4843윤현수6/20/20179956socket통신에 관한 질문입니다. [1]
4842오세운6/7/201710648로그인폼 다시 질문드려요. [1]
4841popo6/7/201710426궁금한사항이 있어 질문 드립니다. [1]
4840윤현수6/5/201710432datagridview에 바인딩시킨 dataset.table에 관련된 질문입니다. [2]파일 다운로드1
4839오세운6/2/201711345로그인폼 만들기 [1]
4838후배5/29/201712054PDF Reader 라이브러리.. [3]
4837KDP5/29/201711562c++ to C# 컨버팅 문의 [2]
4836popo5/26/201714661리플렉션 성능 관련 질문 드립니다. [2]
4835guest5/25/201710466wpf Canvas 질문드립니다. [1]
4834부탁드립...5/19/201711362익스체인지 서버 구동중 인증서를 받는 과정에서오류가 납니다 [1]
4833안종윤5/18/201711766winform을 Web Browser에 붙일 수 있는지요? [1]
4832guest5/17/201711230c# UDP socket예제 실행방법 [3]
4831guest5/15/201713602WPF .net 3.5에서 TextBox 한글 문제 [3]
4830초보자5/7/201718474프로그램 비정상 종료 메시지 창 없애는 방법 [4]
4829윤현수4/26/201714858System.Text.Encoding 질문 [1]
... 31  32  33  34  35  36  37  38  39  [40]  41  42  43  44  45  ...