首页 文章

如何使用SPROC参数从SubSonic SPROC调用返回强类型对象?

提问于
浏览
0

我有一个数据调用方法,返回ItemDatumCollection类型的SubSonic集合 .

sproc执行如下:

itemDatumCollection.LoadAndCloseReader(sp.GetReader());

但是,我无法以这种方式访问sproc的输出参数,因为我可以在调用sp.GetDataSet()时执行以下操作:

itemsDataSet = sp.GetDataSet();

            actualNumberOfResults = ((Int64)sp.OutputValues[1]);
            numberOfResultsReturned = ((Int64)sp.OutputValues[2]);

有没有办法用第一种方法访问sproc的输出参数 - 从我的sproc调用中返回一个SubSonic强类型集合?

谢谢 .

1 回答

  • 0

    我想做类似的事情,最后改变了大部分的StoredProcedures.tt文件,我想一些SubSonic的内部 . 没有太详细,我改变.tt文件,以便它为给定的存储过程生成这个:

    public void COMPANIES_ACTIVATE_PACKAGE(long PI_COMPANY_ID, string PI_ACTIVE, long PI_USER_ID, out long PO_ERRCODE, out string PO_ERRMSG, out string PO_ORA_ERRMSG){
            StoredProcedure sp=new StoredProcedure("COMPANIES.ACTIVATE_PACKAGE",this.Provider);
            sp.Command.AddParameter("PI_COMPANY_ID",PI_COMPANY_ID,DbType.Decimal);
            sp.Command.AddParameter("PI_ACTIVE",PI_ACTIVE,DbType.AnsiString);
            sp.Command.AddParameter("PI_USER_ID",PI_USER_ID,DbType.Decimal);
            sp.Command.AddOutputParameter("PO_ERRCODE",DbType.AnsiString);
            sp.Command.AddOutputParameter("PO_ERRMSG",DbType.AnsiString);
            sp.Command.AddOutputParameter("PO_ORA_ERRMSG",DbType.AnsiString);
            sp.Execute();
            var prms = sp.Command.Parameters;
            PO_ERRCODE = ConvertValue<long>(prms.GetParameter("PO_ERRCODE").ParameterValue);
            PO_ERRMSG = ConvertValue<string>(prms.GetParameter("PO_ERRMSG").ParameterValue);
            PO_ORA_ERRMSG = ConvertValue<string>(prms.GetParameter("PO_ORA_ERRMSG").ParameterValue);
        }
    

    所以基本上我传入任何sproc参数,并为返回值定义'out'参数 .

    这里也没有显示,但是如果我有一个InOut参数,那么我将它传递给 ref 而不是 out .

    然后在我的实际应用程序代码中,我可以像任何其他函数一样调用存储过程:

    long errorCode;
    string errorMsg, oraErrorMsg;
    
    db.COMPANIES_ACTIVATE_PACKAGE(123, "Y", 456, out errorCode, out errorMsg, out oraErrorMsg);
    
    if(errorCode > 0)
        // ... handle error...
    

    我不知道这是否会在没有进一步更改的情况下直接插入SS,但这是我的.tt文件 . 你也许可以使用它,或者至少得到一些关于去哪里的想法:

    StoredProcedures.tt:

    <#@ template language="C#" debug="False" hostspecific="True"  #>
    <#@ output extension=".cs" #>
    <#@ include file="DB2DataProvider.ttinclude" #>
    <#
        var sps = GetSPs(); 
        if(sps.Count>0){ 
    #>  
    using System;
    using System.Data;
    using System.ComponentModel;
    using SubSonic;
    using SubSonic.Schema;
    using SubSonic.DataProviders;
    
    namespace <#=Namespace#>{
        public partial class <#=DatabaseName#>DB{
    
            public T ConvertValue<T>(object paramVal)
            {
                if (paramVal == null || Convert.IsDBNull(paramVal))  // if the value is null, return the default for the desired type.
                    return default(T);
                if (typeof(T) == paramVal.GetType())  // if types are already equal, no conversion needed. just cast.
                    return (T)paramVal;
                else // types don't match. try to convert.
                {
                    var conversionType = typeof(T);
                    if (conversionType.IsGenericType && conversionType.GetGenericTypeDefinition().Equals(typeof(Nullable<>)))
                    {
                        NullableConverter nullableConverter = new NullableConverter(conversionType);
                        conversionType = nullableConverter.UnderlyingType;
                    }
                    return (T)Convert.ChangeType(paramVal, conversionType);
                }
            }
    
    <#  foreach(var sp in sps){#>
            public void <#=sp.CleanName#>(<#=sp.ArgList#>){
                StoredProcedure sp=new StoredProcedure("<#=sp.Name#>",this.Provider);
    <#      foreach(var par in sp.Parameters) {
              if(par.In && !par.Out) {#>
                sp.Command.AddParameter("<#=par.Name#>",<#=par.CleanName#>,DbType.<#=par.DbType#>);
    <#        } else if(!par.In && par.Out) {#>
                sp.Command.AddOutputParameter("<#=par.Name#>",DbType.<#=par.DbType#>);
    <#        } else {#>
                sp.Command.AddParameter("<#=par.Name#>",<#=par.CleanName#>,DbType.<#=par.DbType#>,ParameterDirection.InputOutput);
    <#      }}#>
                sp.Execute();
    <#      bool hasOut = false;
            foreach(var par in sp.Parameters) {
              if(par.Out)
                hasOut = true;
            }
            if(hasOut) {
    #>
                var prms = sp.Command.Parameters;
    <#      }
            foreach(var par in sp.Parameters) {
              if(par.Out) {#>
                <#=par.Name#> = ConvertValue<<#=par.SysType#>>(prms.GetParameter("<#=par.Name#>").ParameterValue);
    <#      }}#>
            }
    <#  }#>
    
        }
    
    }
    <#  }#>
    

    我很确定我还必须更改在数据库提供程序.ttinclude文件中加载存储过程数据的查询,以加载指示它是In,Out还是InOut参数类型的列 .

    ...希望这在某种程度上有所帮助......

相关问题