9. Models 폴더의 DotNetNote 폴더에 NoteRepository.cs 파일을 생성한다. 8번에서 생성한 INoteRepository 인터페이스를 상속해 각각의 메서드를 구현하는 NoteRepository 클래스를 다음과 같이 구현한다. 게시판의 데이터가 저장될 Notes 테이블에 대한 CRUD 코드를 모두 담고 있는 클래스다. 이 클래스의 내용은 웹 폼 방식 게시판을 구현할 때 사용한 NoteRepository 클래스와 형태가 거의 비슷하나, ASP.NET Core 1.0에서 제공하는 DI(Dependency Injection) 방식에 따라서 생성자에 인터페이스를 매개 변수로 하는 주입 방식을 사용하는 부분이 조금 다르고, ASP.NET Core 1.0의 로깅 기능도 기본으로 사용하도록 설정했다. 또한, appsettings.json 파일에 지정한 데이터베이스 연결 문자열을 가져오기 위해서 IConfiguration 개체를 주입하는 코드도 눈에 띈다. 실제로 작업할 때는 다음 코드에서 Repository 클래스의 모든 내용을 먼저 작성하기보다는 입력 페이지 만들 때 Add()를 만들고, 출력 페이지 만들 때 GetAll()을 만드는 식으로 주로 페이지 단위로 만들면서 추가하기도 한다. 물론 명확하게 업무가 확정되면 리파지터리를 먼저 구현하고, 각각의 컨트롤러의 액션 메서드와 그에 해당하는 뷰 페이지를 작성할 수도 있다. 하지만 대부분은 두 가지 방식을 병행해서 그때그때 필요한 메서드를 구현해 사용해도 전혀 상관없다.

▼  /Models/DotNetNote/NoteRepository.cs

using Dapper;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Logging;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.Linq;

namespace DotNetNote.Models
{
  public class NoteRepository : INoteRepository
  {
      private IConfiguration _config;
      private SqlConnection con;
      private ILogger<NoteRepository> _logger;
      
      /// <summary>
      /// 환경변수와 로그 개체 주입
      /// </summary>
      public NoteRepository(
          IConfiguration config, ILogger<NoteRepository> logger)
      {
          _config = config;
          con = new SqlConnection(_config.GetSection(“ConnectionStrings”)
              .GetSection(“DefaultConnection”).Value);
          _logger = logger;
      }
      
      /// <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)
      {
          _logger.LogInformation(“데이터 입력”);
          try
          {
              SaveOrUpdate(vm, BoardWriteFormType.Write);
          }
          catch (System.Exception ex)
          {
              _logger.LogError(“데이터 입력 에러: “ + ex);
          }
      }
      
      /// <summary>
      /// 수정하기
      /// </summary>
      public int UpdateNote(Note vm)
      {
          int r = 0;
          _logger.LogInformation(“데이터 수정”);
          try
          {
              r = SaveOrUpdate(vm, BoardWriteFormType.Modify);
          }
          catch (System.Exception ex)
          {
              _logger.LogError(“데이터 수정 에러: “ + ex);
          }
          return r;
      }
      
      /// <summary>
      /// 답변 글쓰기
      /// </summary>
      public void ReplyNote(Note vm)
      {
          _logger.LogInformation(“데이터 답변”);
          try
          {
              SaveOrUpdate(vm, BoardWriteFormType.Reply);
          }
          catch (System.Exception ex)
          {
              _logger.LogError(“데이터 답변 에러: “ + ex);
          }
      }
      
      /// <summary>
      /// 게시판 리스트 
      /// </summary>
      /// <param name=“page”>페이지 번호</param>
      public List<Note> GetAll(int page)
      {
          _logger.LogInformation(“데이터 출력”);
          try
          {
              var parameters = new DynamicParameters(new { Page = page });
              return con.Query<Note>(“ListNotes”, parameters,
                  commandType: CommandType.StoredProcedure).ToList();
          }
          catch (System.Exception ex)
          {
              _logger.LogError(“데이터 출력 에러: “ + ex);
              return null;
          }
      }
      
      /// <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)
          {
              _logger.LogError(“카운트 출력 에러: “ + ex);
              return -1;
          }
      }
      
      /// <summary>
      /// Notes 테이블의 모든 레코드 수
      /// </summary>
      public int GetCountAll()
      {
          try
          {
              return con.Query<int>(
                  “Select Count(*) From Notes”).SingleOrDefault();
          }
          catch (System.Exception)
          {
              _logger.LogError(“에러 발생”);
              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개 출력: DotNetNote_NewPhotos.cshtml
      /// </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>
      /// 최근 글 리스트: Home\Index.cshtml
      /// </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();
      }
      
      /// <summary>
      /// 특정 게시물을 공지사항(NOTICE)으로 올리기
      /// </summary>
      public void Pinned(int id)
      {
          con.Execute(
              “Update Notes Set Category = ‘Notice’ Where Id = @Id”
              , new { Id = id });
      }
  }
}

---