EDB Postgresを.NET Frameworkから使ってみよう(プロシージャの実行)

create or replace procedure double_proc(v_src number, v_dest out number)
is
begin
v_dest := v_src * 2;
end;

Dim command As EDBCommand = New EDBCommand("double_proc(:in_param, :out_param)", conn)
command.CommandType = CommandType.StoredProcedure
command.Parameters.Add(
    New EDBParameter(
        "in_param",
        EDBTypes.EDBDbType.Integer,
        100,
        "in_param",
        ParameterDirection.Input, False, 2, 2,
        System.Data.DataRowVersion.Current,
        10
    )
)
command.Parameters.Add(
    New EDBParameter(
        "out_param",
        EDBTypes.EDBDbType.Integer,
        100,
        "out_param",
        ParameterDirection.Output, False, 2, 2,
        System.Data.DataRowVersion.Current,
        1
    )
)
' prepareを実行
command.Prepare()
' INパラメータに10を指定し実行
command.Parameters("in_param").Value = 10
command.ExecuteNonQuery()
' OUTパラメータには10*2の20が代入されている
Console.WriteLine(command.Parameters("out_param").Value)

create or replace procedure refcur_proc(v_deptno number, v_result out sys_refcursor)
is
begin
open v_result for select ename from emp where deptno = v_deptno;
end;

Dim tran As EDBTransaction = conn.BeginTransaction() ' point1
Dim command As EDBCommand = New EDBCommand("refcur_proc(:in_param, :out_param)", conn)
command.CommandType = CommandType.StoredProcedure
command.Parameters.Add(
    New EDBParameter(
        "in_param",
        EDBTypes.EDBDbType.Integer,
        100,
        "in_param",
        ParameterDirection.Input, False, 2, 2,
        System.Data.DataRowVersion.Current,
        10
    )
)
command.Parameters.Add(
    New EDBParameter(
        "out_param",
        EDBTypes.EDBDbType.RefCursor, ' point2
        1000,
        "out_param",
        ParameterDirection.Output, False, 2, 2,
        System.Data.DataRowVersion.Current,
        DBNull.Value
    )
)
command.Prepare()
command.Parameters("in_param").Value = 10
command.ExecuteNonQuery()
Dim reader As EDBDataReader = command.Parameters("out_param").Value ' point3
:
reader.Close()
tran.Rollback()

EnterpriseDB.EDBClient.EDBException:
cursor "unnamed portal 1" does not exist

筆者情報

• 山田 聡

2011年にアシストに入社してからサポートセンターでOracle DatabaseやPostgreSQL、EDB Postgres Advanced Server(EPAS)といったデータベース製品を中心に担当しています。個人的にJavaやNode.js、Python等を触っていますので、PostgreSQLと絡めてアプリケーション周りの情報をお送りしていきます。