5. 나는 SQL Server와 같은 데이터 저장소와 연관된 모든 코드는 Repository로 끝나는 클래스에 모아 놓는다. Models 폴더에 NoteRepository.cs 파일을 생성하고 이곳에 데이터 입출력 관련된 모든 코드를 작성하자. 순수 ADO.NET, Entity Framework, Dapper 등 원하는 방식으로 데이터베이스 프로그래밍을 진행하면 되는데 이번 게시판 프로젝트는 Micro ORM인 Dapper를 사용한다. 앞서 웹 프로젝트에 NuGet을 사용해 Dapper.dll 파일이 추가되었다면 다음 코드를 입력하자.

▼  ~/DotNetNote/Models/NoteRepository.cs

using Dapper;
using System.Collections.Generic;
using System.Configuration;
using System.Data;
using System.Data.SqlClient;
using System.Linq;

namespace DotNetNote.Models
{
  public class NoteRepository
  {
      private SqlConnection con;
      
      public NoteRepository()
      {
          con = new SqlConnection(ConfigurationManager.ConnectionStrings[
              “ConnectionString”].ConnectionString);
      }
      
      /// <summary>
      /// 데이터 저장, 수정, 답변 공통 메서드
      /// </summary>
      public int SaveOrUpdate(Note n, BoardWriteFormType formType)
      {
          int r = 0;
          
          // 파라미터 추가
          var p = new DynamicParameters();
          
          //[a] 공통
          p.Add(”@Name”, value: n.Name, dbType: DbType.String);
          p.Add(”@Email”, value: n.Email, dbType: DbType.String);
          p.Add(”@Title”, value: n.Title, dbType: DbType.String);
          p.Add(”@Content”, value: n.Content, dbType: DbType.String);
          p.Add(”@Password”, value: n.Password, dbType: DbType.String);
          p.Add(”@Encoding”, value: n.Encoding, dbType: DbType.String);
          p.Add(”@Homepage”, value: n.Homepage, dbType: DbType.String);
          p.Add(”@FileName”, value: n.FileName, dbType: DbType.String);
          p.Add(”@FileSize”, value: n.FileSize, dbType: DbType.Int32);
          
          switch (formType)
          {
              case BoardWriteFormType.Write:
                  // [b] 글쓰기 전용
                  p.Add(”@PostIp”, value: n.PostIp, dbType: DbType.String);
                  
                  r = con.Execute(“WriteNote”, p
                      , commandType: CommandType.StoredProcedure);
                  break;
              case BoardWriteFormType.Modify:
                  // [b] 수정하기 전용
                  p.Add(”@ModifyIp”,
                      value: n.ModifyIp, dbType: DbType.String);
                  p.Add(”@Id”, value: n.Id, dbType: DbType.Int32);
                  
                  r = con.Execute(“ModifyNote”, p,
                      commandType: CommandType.StoredProcedure);
                  break;
              case BoardWriteFormType.Reply:
                  // [b] 답변쓰기 전용
                  p.Add(”@PostIp”, value: n.PostIp, dbType: DbType.String);
                  p.Add(”@ParentNum”,
                      value: n.ParentNum, dbType: DbType.Int32);
                  
                  r = con.Execute(“ReplyNote”, p,
                      commandType: CommandType.StoredProcedure);
                  break;
          }
          
          return r;
      }
      
      /// <summary>
      /// 게시판 글쓰기
      /// </summary>
      public void Add(Note vm)
      {
          try
          {
              SaveOrUpdate(vm, BoardWriteFormType.Write);
          }
          catch (System.Exception ex)
          {
              throw new System.Exception(ex.Message); // 로깅 처리 권장 영역
          }
      }
      
      /// <summary>
      /// 수정하기
      /// </summary>
      public int UpdateNote(Note vm)
      {
          int r = 0;
          try
          {
              r = SaveOrUpdate(vm, BoardWriteFormType.Modify);
          }
          catch (System.Exception ex)
          {
              throw new System.Exception(ex.Message);
          }
          return r;
      }
      
      /// <summary>
      /// 답변 글쓰기
      /// </summary>
      public void ReplyNote(Note vm)
      {
          try
          {
              SaveOrUpdate(vm, BoardWriteFormType.Reply);
          }
          catch (System.Exception ex)
          {
              throw new System.Exception(ex.Message);
          }
      }
      
      /// <summary>
      /// 게시판 리스트
      /// </summary>
      /// <param name=“page”>페이지 번호</param>
      public List<Note> GetAll(int page)
      {
          try
          {
              var parameters = new DynamicParameters(new { Page = page });
              return con.Query<Note>(“ListNotes”, parameters,
                  commandType: CommandType.StoredProcedure).ToList();
          }
          catch (System.Exception ex)
          {
              throw new System.Exception(ex.Message);
          }
      }
      
      /// <summary>
      /// 검색 카운트
      /// </summary>
      public int GetCountBySearch(string searchField, string searchQuery)
      {
          try
          {
              return con.Query<int>(“SearchNoteCount”, new
              {
                  SearchField = searchField,
                  SearchQuery = searchQuery
              },
                  commandType: CommandType.StoredProcedure)
                  .SingleOrDefault();
          
          }
          catch (System.Exception ex)
          {
              throw new System.Exception(ex.Message);
          }
      }
      
      /// <summary>
      /// Notes 테이블의 모든 레코드 수
      /// </summary>
      public int GetCountAll()
      {
          try
          {
              return con.Query<int>(
                  “Select Count(*) From Notes”).SingleOrDefault();
          }
          catch (System.Exception)
          {
              return -1;
          }
      }
      
      /// <summary>
      /// Id에 해당하는 파일명 반환
      /// </summary>
      public string GetFileNameById(int id)
      {
          return
              con.Query<string>(“Select FileName From Notes Where Id = @Id”,
              new { Id = id }).SingleOrDefault();
      }
      
      /// <summary>
      /// 검색 결과 리스트
      /// </summary>
      public List<Note> GetSeachAll(
          int page, string searchField, string searchQuery)
      {
          var parameters = new DynamicParameters(new
          {
              Page = page,
              SearchField = searchField,
              SearchQuery = searchQuery
          });
          return con.Query<Note>(“SearchNotes”, parameters,
              commandType: CommandType.StoredProcedure).ToList();
      }
      
      /// <summary>
      /// 다운 카운트 1 증가
      /// </summary>
      public void UpdateDownCount(string fileName)
      {
          con.Execute(“Update Notes Set DownCount = DownCount + 1 “
              + ” Where FileName = @FileName”, new { FileName = fileName });
      }
      public void UpdateDownCountById(int id)
      {
          var p = new DynamicParameters(new { Id = id });
          con.Execute(“Update Notes Set DownCount = DownCount + 1 “
          + ” Where Id = @Id”, p, commandType: CommandType.Text);
      }
      
      /// <summary>
      /// 상세보기
      /// </summary>
      public Note GetNoteById(int id)
      {
          var parameters = new DynamicParameters(new { Id = id });
          return con.Query<Note>(“ViewNote”, parameters,
              commandType: CommandType.StoredProcedure).SingleOrDefault();
      }
      
      /// <summary>
      /// 삭제
      /// </summary>
      public int DeleteNote(int id, string password)
      {
          return con.Execute(“DeleteNote”,
              new { Id = id, Password = password },
              commandType: CommandType.StoredProcedure);
      }
      
      /// <summary>
      /// 최근 올라온 사진 리스트 4개 출력
      /// </summary>
      public List<Note> GetNewPhotos()
      {
          string sql =
              “SELECT TOP 4 Id, Title, FileName, FileSize FROM Notes “
              + ” Where FileName Like ‘%.png’ Or FileName Like ‘%.jpg’ Or “
              + ” FileName Like ‘%.jpeg’ Or FileName Like ‘%.gif’ “
              + ” Order By Id Desc”;
          return con.Query<Note>(sql).ToList();
      }
      
      /// <summary>
      /// 최근 글 리스트
      /// </summary>
      public List<Note> GetNoteSummaryByCategory(string category)
      {
          string sql = “SELECT TOP 3 Id, Title, Name, PostDate, FileName, “
              + ” FileSize, ReadCount, CommentCount, Step “
              + ” FROM Notes “
              + ” Where Category = @Category Order By Id Desc”;
          return con.Query<Note>(sql, new { Category = category }).ToList();
      }
      
      /// <summary>
      /// 최근 글 리스트 전체(최근 글 5개 리스트)
      /// </summary>
      public List<Note> GetRecentPosts()
      {
          string sql = “SELECT TOP 3 Id, Title, Name, PostDate FROM Notes “
              + ” Order By Id Desc”;
          return con.Query<Note>(sql).ToList();
      }
      
      /// <summary>
      /// 최근 글 리스트 n개
      /// </summary>
      public List<Note> GetRecentPosts(int numberOfNotes)
      {
          string sql =
              $“SELECT TOP {numberOfNotes} Id, Title, Name, PostDate “
              + ” FROM Notes Order By Id Desc”;
          return con.Query<Note>(sql).ToList();
      }
  }
}

---