Microsoft MVP성태의 닷넷 이야기
ef core, FromSqlRaw 맵핑 질문입니다. [링크 복사], [링크+제목 복사],
조회: 1964
글쓴 사람
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,... 등의 타입을 가져갈 수밖에 없습니다.
정성태

1  2  3  4  5  6  7  8  9  [10]  11  12  13  14  15  ...
NoWriterDateCnt.TitleFile(s)
5704따봉이8/4/20224715EventHandler 관련 [1]
5703조민준8/3/20224152안녕하세요 정적 멤버 초기화 관련 간단한 질문 [2]
5702석우8/3/20224049C# WPF Ribbon IsMinimized 프로퍼티 변경 감지 방법문의 [2]파일 다운로드1
5701김기헌8/1/20224285foreach 문으로 컬렉션을 열거할 때 궁금한 점 [2]
5699갓경섭7/29/20224715C# 프로그램 느려짐 현상 [2]
5698kss7/29/20225449ValueTask 질문입니다. [5]
5697스팸7/28/20225494윈도우서버 Port 고갈문제 (Event ID 4227, 4231) [3]파일 다운로드1
5696유석7/27/20225713닷넷 4.X 와 닷넷 6.0 버전 차이 [6]
5695초보코더7/26/20225079[WCF] EndpointNotFoundException 기본 연결이 닫혔습니다. 원격 서버에 연결할 수 없습니다. [1]
5693차가워7/22/20224484socket 종료 시 reveive수신부에서 에러 나는거 처리 문의 [5]
5692도비7/21/20224063Ubuntu LVM 확장 관련 [1]파일 다운로드1
5691따봉이7/21/20224760Task 비동기 UI 크로스 쓰레딩 Err 관련 [1]
5690훈이7/20/20224012wpf질문입니다 [2]
5689질문7/20/20223803비동기 함수를 사용하는 방법에 대한 질문입니다 [1]
5688김정현7/11/20223916소스 디버깅(F5)시 프로그램 켜지지 않고 디버깅 가능한 상태 [1]
5687규철7/6/20224047개발업무 문서 관리 방법 문의 [3]
5686권용완7/5/20224021Linq Entites 에서 string[]에 담긴 데이터를 제외하는 방법 문의 [3]
5685차가워7/4/20224189메모리 선택 문의 [1]
5683김민혁7/1/20224702HttpWebRequest POST 전송 관련해서 질문 드립니다. [4]파일 다운로드1
5682김기헌6/20/20224180안녕하세요 서로 다른 스레드에서 동일 인스턴스의 메소드를 호출할때 질문드립니다 [2]
5681미래는투...6/19/20224091VC++ 빌드 관련 문의 (h파일이 바뀌었는데 컴파일을 꼭 하지 않아도 되나요?) [1]
5680Syong6/12/20225110EXE파일에 속성값 추가하는 방법이 있나요? [2]파일 다운로드1
5679차가워6/8/20224278tcpip socket 여러 랜카드 사용 시 연결 문의 [1]
5678차가워6/7/20224184원자적 실행 문의 [3]
5677장성욱6/7/20224211블루투스 포트와 시리얼포트 연결시 에러 [2]
5675차가워5/29/20224892윈도우설정 프로세스사용계획 옵션과 c# 스레드 [1]
1  2  3  4  5  6  7  8  9  [10]  11  12  13  14  15  ...