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

... 46  47  48  49  50  51  52  53  54  [55]  56  57  58  59  60  ...
NoWriterDateCnt.TitleFile(s)
1309서동원8/12/201418105안녕하세요. embeded dll과 관련하여 질문드립니다. [4]
1308김솔8/11/201422257리스트뷰에서 중복파일체크를 하고싶습니다. [3]
1306이상현8/7/201415827Entity 프레임웍에서 테이블만 추가로 등록하는 방법
1307이상현8/7/201416331    답변글 [답변]: 자답이네요. [1]
1305popo8/7/201417445wpf UserControl List 바인딩 질문 입니다. [1]
1304민경수8/7/201420475네이버 카페에 구글 스프레드 시트 삽입 [1]
1303김동진8/7/201417610vmware환경에서 Guest IP를 192대역으로 받을 수 있는 방법은 없을까요~? [3]
1302김문경7/31/201416520스마트클라이언트 오라클 연결 [1]
1314이재균8/20/201416609    답변글 [답변]: 스마트클라이언트 오라클 연결
1300아로스7/28/201430168c# 인터넷 임시 파일 삭제 문의 [12]파일 다운로드1
1299서동원7/28/201418553안녕하세요. 혹시 Internet_Zone과 관련된문제인가 해서 질문드립니다. [1]
1298(non...7/25/201424749(글쓴이의 요청으로 삭제합니다.) [15]
1295서동원7/22/201419722안녕하세요. 스마트클라이언트에 대해 질문드립니다. [2]파일 다운로드1
1294(non...7/20/201417992(글쓴이의 요청으로 삭제합니다.) [2]
1293VS20...7/20/201419404VS2013 Ultimate에 Windows Phone 프로젝트 템플릿 추가 방법 문의 [1]파일 다운로드2
1292(non...7/20/201416909(글쓴이의 요청으로 삭제합니다.) [2]
1291zino7/16/201418610chromium 배포본 만들기~ [1]
1290(non...7/13/201419388(글쓴이의 요청으로 삭제합니다.) [3]
1288박주만7/8/201428614C# 서비스 기반 데이터베이스(mdf) & InstallShield Limited Edition 설치 및 배포 [2]파일 다운로드1
1287김용환7/8/201426718오라클 db 사용관련 문의입니다. [4]파일 다운로드1
1286C#조으다7/8/201416905WebBrowser 공유기 관리 웹 페이지 인증 [3]
1285C#조으다7/5/201417253IE DocumentComplete 이벤트가 발생되지 않습니다. [2]
1284(non...7/4/201417561(글쓴이의 요청으로 삭제합니다.) [3]
1283김영대7/3/201420361안녕하십니까 정성태님 죄송하지만 SmartClient 에 관한 질문이 있습니다. [9]
1282(non...7/2/201417440(글쓴이의 요청으로 삭제합니다.) [2]
1281(non...7/1/201418707(글쓴이의 요청으로 삭제합니다.) [4]
... 46  47  48  49  50  51  52  53  54  [55]  56  57  58  59  60  ...