응용 프로그램에서 부르기

CREATE OR ALTER PROCEDURE Board.P_POST_LIST_DEMO
    @board_num int,
    @size      int = 20,
    @total     int = 0 OUTPUT
AS
BEGIN
    SET NOCOUNT ON;
    SELECT @total = COUNT(*) FROM Board.POSTS WHERE board_num = @board_num;

    SELECT TOP (@size) num, title, user_num, reg_date, hit_count
    FROM Board.POSTS WHERE board_num = @board_num
    ORDER BY group_num DESC, sort_no;

    RETURN 0;
END

await using var con = new SqlConnection(cs);
await using var cmd = new SqlCommand("Board.P_POST_LIST_DEMO", con);
cmd.CommandType = CommandType.StoredProcedure;

// 형식과 크기를 지정합니다. 뒤에서 까닭을 봅니다.
cmd.Parameters.Add("@board_num", SqlDbType.Int).Value = 2;
cmd.Parameters.Add("@size", SqlDbType.Int).Value = 3;

// OUTPUT 매개 변수
var total = cmd.Parameters.Add("@total", SqlDbType.Int);
total.Direction = ParameterDirection.Output;

// RETURN 값
var ret = cmd.Parameters.Add("@ret", SqlDbType.Int);
ret.Direction = ParameterDirection.ReturnValue;

await con.OpenAsync();
await using var r = await cmd.ExecuteReaderAsync();

// 열 번호를 미리 얻어 두면 행마다 이름을 찾지 않습니다.
int numOrd = r.GetOrdinal("num"), titleOrd = r.GetOrdinal("title");
while (await r.ReadAsync())
    Console.WriteLine($"  {r.GetInt32(numOrd),4}  {r.GetString(titleOrd)}");

// 리더를 닫아야 OUTPUT 과 RETURN 이 채워집니다.
await r.CloseAsync();
Console.WriteLine($"  총건수 = {total.Value}   반환값 = {ret.Value}");

cmd.Parameters.AddWithValue("@t", "인덱스 질문드립니다");
var p = cmd.Parameters["@t"];
Console.WriteLine($"  형식: {p.SqlDbType}({p.Size})");

string[] words = { "가", "가나", "가나다", "가나다라", "가나다라마" };

foreach (var w in words) {
    await using var cmd = new SqlCommand(
        "SELECT COUNT(*) FROM Board.POSTS WHERE title = @t", con);
    cmd.Parameters.AddWithValue("@t", w);          // 짐작하게 두면
    // cmd.Parameters.Add("@t", SqlDbType.NVarChar, 200).Value = w;   // 정해 주면
    await cmd.ExecuteScalarAsync();
}

IF LEN(LTRIM(RTRIM(@title))) = 0
BEGIN
    THROW 50001, N'제목을 입력하십시오.', 1;
END

try {
    await cmd.ExecuteNonQueryAsync();
    Console.WriteLine($"  넣었습니다. num = {num.Value}");
}
catch (SqlException ex) {
    Console.WriteLine($"  Number={ex.Number}  Class={ex.Class}  \"{ex.Message}\"");
}

catch (SqlException ex) when (ex.Number == 50001) {
    // 사람이 고칠 수 있는 것 — 화면에 그대로 보여 줍니다.
    ModelState.AddModelError("", ex.Message);
}
catch (SqlException ex) when (ex.Number == 2627 || ex.Number == 2601) {
    // 키 중복(3.3) — 이미 있다고 알립니다.
    ModelState.AddModelError("", "이미 등록된 값입니다.");
}
catch (SqlException ex) when (ex.Number == 1205) {
    // 교착(5.5) — 다시 시도해도 되는 오류입니다.
    return await RetryAsync();
}
catch (SqlException ex) {
    // 그 밖의 것은 기록하고 일반 오류 화면으로 보냅니다.
    _logger.LogError(ex, "프로시저 호출 실패");
    throw;
}

CREATE TYPE Board.PostNumList AS TABLE (num int NOT NULL PRIMARY KEY);
GO

CREATE OR ALTER PROCEDURE Board.P_HIT_BUMP_DEMO
    @nums Board.PostNumList READONLY
AS
BEGIN
    SET NOCOUNT ON;
    UPDATE p SET hit_count = p.hit_count + 1
    FROM Board.POSTS p JOIN @nums n ON n.num = p.num;

    SELECT @@ROWCOUNT AS 올린행;
END

var table = new DataTable();
table.Columns.Add("num", typeof(int));
foreach (var n in new[] { 1, 2, 3 }) table.Rows.Add(n);

await using var cmd = new SqlCommand("Board.P_HIT_BUMP_DEMO", con, tx) {
    CommandType = CommandType.StoredProcedure
};

var p = cmd.Parameters.AddWithValue("@nums", table);
p.SqlDbType = SqlDbType.Structured;
p.TypeName  = "Board.PostNumList";      // 스키마까지 적습니다

var affected = await cmd.ExecuteScalarAsync();

await using var con = new SqlConnection(cs);
await con.OpenAsync();
await using var tx = (SqlTransaction)await con.BeginTransactionAsync(
    IsolationLevel.ReadCommitted);

try {
    await using (var c1 = new SqlCommand("…", con, tx))   // tx 를 넘겨야 합니다
        await c1.ExecuteNonQueryAsync();

    await using (var c2 = new SqlCommand("SELECT 1/0", con, tx))
        await c2.ExecuteScalarAsync();

    await tx.CommitAsync();
}
catch (SqlException ex) {
    await tx.RollbackAsync();
    Console.WriteLine($"  Number={ex.Number}  \"{ex.Message}\"  → 롤백했습니다.");
}

Server=…;Database=MAYYANET;
Integrated Security=true;          -- 암호를 적지 않는 쪽이 낫습니다(6.1)
Encrypt=true;                      -- 최신 드라이버는 기본이 true 입니다
TrustServerCertificate=false;      -- 운영에서는 false 로 두고 인증서를 갖춥니다
Application Name=MayyaNet.Web;     -- 누가 부르는지 서버에서 보입니다
Connect Timeout=15;                -- 연결이 안 될 때 기다리는 시간
Max Pool Size=100;                 -- 기본값입니다

public class PostItem(DataConfiguration? dbConfig) : BizItemBase(dbConfig) {

    [DataName("views", SpType.Select | SpType.List)]
    public int Views { get; set; } = 0;

    [DataName("likes", SpType.Select | SpType.List)]
    public int Likes { get; set; } = 0;
}

public class PostItemList(DataConfiguration? dbConfig)
    : BizItemListBase<PostItem, PostListConditions>(dbConfig) {

    protected override Dictionary<SpType, string> StoredProcedures
        => new() {
            { SpType.List, "Blog.P_POST_LIST" }
        };
}

public void SequenceUpdate(int id, int sequence) {
    var sp = StoredProcedures[SpType.Sequence];
    var pt = new ParameterTable {
        { GetDataName(nameof(Id))!, id },
        { GetDataName(nameof(Sequence))!, sequence }
    };

    Modifier?.AddParams(pt, SpType.Delete);
    ExecuteNonQuery(sp, pt);
}