Dapper是否支持SQL 2008表值参数2？
我知道dapper可以支持TVF，但是你如何与TVF一起发送额外的参数（不将它添加到IntDynamicParam类）？ 请参阅Tests.cs中的以下示例，我已修改为添加额外参数：
connection.Execute("CREATE TYPE int_list_type AS TABLE (n int NOT NULL PRIMARY KEY)"); connection.Execute("CREATE PROC get_ints @x int, @ints int_list_type READONLY AS select * from @ints"); 我尝试了以下但是遇到了错误（从对象类型SqlMapper.Tests + IntDynamicParam到已知的托管提供者本机类型没有映射。）：
var p = new DynamicParameters(); p.Add("x", 4); p.Add("ints",new IntDynamicParam(new int[] { 1, 2, 3 })); var nums = connection.Query("get_ints", p).ToList();
谢谢Sam的回复，但问题有点不同。 我想知道如何传入另一个变量和元组。 请参阅下面的修改后的SP：
CREATE TYPE int_tuple_list_type AS TABLE (n int NOT NULL PRIMARY KEY, n2 int) CREATE PROC get_int_tuples @someVar varchar(10), @ints int_tuple_list_type READONLY AS select * from @ints
关于IDynamicParameters魔力很少，你需要担心的是在准备运行的开放IDbCommand上实现AddParameters 。
假设您想要一个整数元组，您可以实现以下内容：
CREATE TYPE int_tuple_list_type AS TABLE (n int NOT NULL PRIMARY KEY, n2 int) CREATE PROC get_int_tuples @ints int_tuple_list_type READONLY AS select * from @ints
其次是：
class TupleIntDynamicParam : Dapper.SqlMapper.IDynamicParameters { IEnumerable tuples; public IntDynamicParam(IEnumerable> tuples) { this.tuples= tuples; } public void AddParameters(IDbCommand command) { var sqlCommand = (SqlCommand)command; sqlCommand.CommandType = CommandType.StoredProcedure; List number_list = new List(); // Create an SqlMetaData object that describes our table type. Microsoft.SqlServer.Server.SqlMetaData[] tvp_definition = { new Microsoft.SqlServer.Server.SqlMetaData("n", SqlDbType.Int), new Microsoft.SqlServer.Server.SqlMetaData("n2", SqlDbType.Int) }; foreach (int n in tuples) { // Create a new record, using the metadata array above. Microsoft.SqlServer.Server.SqlDataRecord rec = new Microsoft.SqlServer.Server.SqlDataRecord(tvp_definition); rec.SetInt32(0, n.Item1); rec.SetInt32(1, n.Item2); number_list.Add(rec); // Add it to the list. } // Add the table parameter. var p = sqlCommand.Parameters.Add("ints", SqlDbType.Structured); p.Direction = ParameterDirection.Input; p.TypeName = "int_tuple_list_type"; p.Value = number_list; } }
然后你可以传入元组：
var nums = connection.Query("get_int_tuples", new TupleIntDynamicParam (new Tuple[] { Tuple.Create(1,2), Tuple.Create(2,3) })).ToList();
这是一个完整的解决方案，使用ICustomQueryParameter接口和我编写的一些代码（在附页的底部），让你使用dapper将任何IEnumerable发送到storedprocedure，即使T有多个属性：
这是链接中的代码：
/// /// Send DataTable as dapper parameter /// public class DapperTableParameter : ICustomQueryParameter { protected DataTable _table = null; public DapperTableParameter(DataTable table) { _table = table; } public void AddParameter(System.Data.IDbCommand command, string name) { // This is SqlConnection specific ((SqlCommand)command).Parameters.Add("@" + name, SqlDbType.Structured).Value = _table; } } public class DapperTVP : DapperTableParameter { public DapperTVP(IEnumerable list) : base(new System.Data.DataTable()) { var t = typeof(T); var propertyByName = new Dictionary(); foreach (var p in t.GetProperties()) { propertyByName.Add(p.Name, p); _table.Columns.Add(p.Name, p.PropertyType); } foreach (var i in list) { var row = _table.NewRow(); foreach (var p in propertyByName) { row[p.Key] = p.Value.GetValue(i, null); } _table.Rows.Add(row); } } }
你仍然需要像这样合并ICustomQueryParameter ： http ： //code.google.com/p/dapper-dot-net/issues/attachmentText？ ICustomQueryParameter
这就是我使用generics类的方法。 这还不完美。 当我对其进行更改时，将更新此post。
public class TableTypeDynamicParam : Dapper.SqlMapper.IDynamicParameters { IEnumerable MyList; Dictionary ordinals; Dictionary typeMap; string ParameterName, TableTypeName; public TableTypeDynamicParam(IEnumerable listValue, string parameterName, string tableTypeName) { this.MyList = listValue; this.ParameterName = parameterName; this.TableTypeName = tableTypeName; ordinals = new Dictionary(); SetTypeMap(); } void SetTypeMap() { typeMap = new Dictionary(); typeMap[typeof(byte)] = SqlDbType.TinyInt; typeMap[typeof(sbyte)] = SqlDbType.TinyInt; typeMap[typeof(short)] = SqlDbType.SmallInt; typeMap[typeof(ushort)] = SqlDbType.SmallInt; typeMap[typeof(int)] = SqlDbType.Int; typeMap[typeof(uint)] = SqlDbType.Int; typeMap[typeof(long)] = SqlDbType.Int; typeMap[typeof(ulong)] = SqlDbType.BigInt; typeMap[typeof(float)] = SqlDbType.Float; typeMap[typeof(double)] = SqlDbType.Float; typeMap[typeof(decimal)] = SqlDbType.Decimal; typeMap[typeof(bool)] = SqlDbType.Bit; typeMap[typeof(string)] = SqlDbType.Text; typeMap[typeof(char)] = SqlDbType.Char; typeMap[typeof(Guid)] = SqlDbType.UniqueIdentifier; typeMap[typeof(DateTime)] = SqlDbType.DateTime; typeMap[typeof(DateTimeOffset)] = SqlDbType.DateTimeOffset; typeMap[typeof(byte[])] = SqlDbType.Binary; typeMap[typeof(byte?)] = SqlDbType.TinyInt; typeMap[typeof(sbyte?)] = SqlDbType.TinyInt; typeMap[typeof(short?)] = SqlDbType.SmallInt; typeMap[typeof(ushort?)] = SqlDbType.SmallInt; typeMap[typeof(int?)] = SqlDbType.Int; typeMap[typeof(uint?)] = SqlDbType.Int; typeMap[typeof(long?)] = SqlDbType.BigInt; typeMap[typeof(ulong?)] = SqlDbType.BigInt; typeMap[typeof(float?)] = SqlDbType.Float; typeMap[typeof(double?)] = SqlDbType.Float; typeMap[typeof(decimal?)] = SqlDbType.Decimal; typeMap[typeof(bool?)] = SqlDbType.Bit; typeMap[typeof(char?)] = SqlDbType.Char; typeMap[typeof(Guid?)] = SqlDbType.UniqueIdentifier; typeMap[typeof(DateTime?)] = SqlDbType.DateTime; typeMap[typeof(DateTimeOffset?)] = SqlDbType.DateTimeOffset; // typeMap[typeof(System.Data.Linq.Binary)] = SqlDbType.Binary; } SqlDbType GetSqlDBType(Type t) { # region other tries /* SqlParameter p1 = new SqlParameter(); TypeConverter tc = TypeDescriptor.GetConverter(p1.DbType); if (tc.CanConvertFrom(theType)) p1.DbType = (DbType)tc.ConvertFrom(theType.Name); else { //Try brute force try { p1.DbType = (DbType)tc.ConvertFrom(theType.Name); } catch {} //Do Nothing } return p1.SqlDbType; Microsoft.SqlServer.Server.SqlMetaData sm = Microsoft.SqlServer.Server.SqlMetaData.InferFromValue(new byte[] { 1, 2 }, "someName"); sm = Microsoft.SqlServer.Server.SqlMetaData.InferFromValue(2.3, "someName"); sm = Microsoft.SqlServer.Server.SqlMetaData.InferFromValue(11, "someName"); sm = Microsoft.SqlServer.Server.SqlMetaData.InferFromValue(System.Web.HttpValidationStatus.Valid, "someName"); sm = Microsoft.SqlServer.Server.SqlMetaData.InferFromValue("hello", "someName"); Console.WriteLine(sm.SqlDbType); Console.WriteLine(sm.TypeName); Console.WriteLine(sm.MaxLength); */ # endregion return typeMap[t]; } void SetRecordValue(ref Microsoft.SqlServer.Server.SqlDataRecord rec, string propertyName, object value, Type propertyType) { switch (propertyType.ToString()) { //need to cover all type case case "System.Int32": rec.SetInt32(ordinals[propertyName], (int)value); break; case "System.Int64": rec.SetInt64(ordinals[propertyName], (long)value); break; case "System.Boolean": rec.SetBoolean(ordinals[propertyName], (bool)value); break; case "System.String": default: rec.SetString(ordinals[propertyName], Convert.ToString(value)); break; } } public void AddParameters(IDbCommand command) { var sqlCommand = (SqlCommand)command; sqlCommand.CommandType = CommandType.StoredProcedure; List tableType_list = new List(); var first = MyList.FirstOrDefault(); if (null != first) { var lstDefinition = new List(); int i = 0; foreach (var prop in first.GetType().GetProperties()) { lstDefinition.Add(new Microsoft.SqlServer.Server.SqlMetaData(prop.Name, GetSqlDBType(prop.PropertyType))); ordinals.Add(prop.Name, i++); } // Create an SqlMetaData object that describes our table type. // Microsoft.SqlServer.Server.SqlMetaData[] tvp_definition = { new Microsoft.SqlServer.Server.SqlMetaData("n", SqlDbType.Int) }; foreach (var l in MyList) { // Create a new record, using the metadata array above. Microsoft.SqlServer.Server.SqlDataRecord rec = new Microsoft.SqlServer.Server.SqlDataRecord(lstDefinition.ToArray()); foreach (var prop in first.GetType().GetProperties()) { // rec.SetInt32(ordinals[prop.Name], prop.GetValue(l)); // Set the value. SetRecordValue(ref rec, prop.Name, prop.GetValue(l), prop.GetType()); } tableType_list.Add(rec); // Add it to the list. } } // Add the table parameter. var p = sqlCommand.Parameters.Add("@" + ParameterName.TrimStart('@'), SqlDbType.Structured); p.Direction = ParameterDirection.Input; p.TypeName = TableTypeName; if (null != first) p.Value = tableType_list; else p.Value = DBNull.Value; } public void AddParameters(IDbCommand command, SqlMapper.Identity identity) { AddParameters(command); } }
有一个nuget包， Dapper TVP ，包括一些使表值参数更容易使用的类。
应该注意的是，包装依赖于Dapper 1.12.1或更高版本。
使用此包将tvp传递给存储过程看起来像这样：
var p = new Dapper.Tvp.DynamicParametersTvp(); SqlMetaData[] tableValuedParameterDefinition = { new SqlMetaData("columnOne", SqlDbType.UniqueIdentifier), new SqlMetaData("columnTwo", SqlDbType.VarBinary, 64) }; var collectionRows = new List(); for (int i = 0; i < collection.Count; i++) { var row = new SqlDataRecord(tableValuedParameterDefinition); row.SetGuid(0, collection[i].Item1); row.SetBytes(1, 0, collection[i].Item2, 0, sessionsAndPins[i].Item2.Length); collectionRows.Add(row); } p.Add(new Dapper.Tvp.TableValueParameter("@tvpName", "tvpTypeName", collectionRows)); using (SqlConnection connection = new SqlConnection(ConnectionManager.GetConnectionString("Database"))) { try { connection.Open(); result = connection.Query("SomeStoredProcedureThatExpectsTVP", p, commandType: CommandType.StoredProcedure).SingleOrDefault(); } finally { connection.Close(); } }
我需要能够传递表值参数和常规参数。 结合@Esen和@ Roger-Joys的答案给了我下面的课程。 此类专门用于使用stringlist_to_table类型，但您可以根据需要进行更改。 对于我来说，为每种TVP类型设置一个特定的方法似乎是有道理的。
CREATE TYPE stringlist_tbltype AS TABLE (s VARCHAR(256))
用法：
var p = new DynamicParametersWithTVP(); p.Add( "@someVar", "abc", DbType.AnsiString ); p.AddTVPString( "@stringlist", new string[] { "abc", "def" } ); using (var conn = new SqlConnection( _cs )) { conn.Open(); return conn.Query( "dbo.stored_proc_name", p, commandType: CommandType.StoredProcedure ); }
这是DynamicParametersWithTVP的实现。 它基本上保留了一个DynamicParameters类来处理非TVP的东西，以及TVP的构建。
class DynamicParametersWithTVP : SqlMapper.IDynamicParameters { private Dictionary _tvpParams; private DynamicParameters _params; public DynamicParametersWithTVP() { _tvpParams = new Dictionary(); _params = new DynamicParameters(); } public void Add( string name, object value = null, DbType? dbType = null, ParameterDirection? direction = null, int? size = null ) { _params.Add( name, value, dbType, direction, size ); } public void AddTVPString( string name, IEnumerable values ) { var metadata = new[] { new SqlMetaData( "one", SqlDbType.VarChar, 256) }; var data = new TVPData { Data = values, MetaData = metadata, Name = name, Type = "stringlist_tbltype", SetData = ( rec, s ) => rec.SetString( 0, (string)s ), }; _tvpParams.Add( name, data ); } public void AddParameters( IDbCommand command, SqlMapper.Identity identity ) { //Adds the regular parameters, then adds any tvp parameters ((SqlMapper.IDynamicParameters)_params).AddParameters( command, identity ); AddTVPCommands( command ); } private void AddTVPCommands( IDbCommand command ) { foreach (var o in _tvpParams) { AddTVPParam( command, o.Key, o.Value ); } } private void AddTVPParam( IDbCommand command, string name, TVPData value ) { var dataList = new List(); if (value.Data != null) { foreach (var d in value.Data) { var rec = new SqlDataRecord( value.MetaData ); value.SetData( rec, d ); //note: this only works for a one-column TVP dataList.Add( rec ); } } if (dataList.Count == 0) { //gotta make the value null if there isn't any data. dataList = null; } var p = ((SqlCommand)command).Parameters.Add( name, SqlDbType.Structured ); p.Direction = ParameterDirection.Input; p.TypeName = value.Type; p.Value = dataList; } private class TVPData { public string Name { get; set; } public string Type { get; set; } public SqlMetaData[] MetaData { get; set; } public IEnumerable Data { get; set; } public Action SetData { get; set; } } }
我更喜欢这样做：
internal class TableTypeDynamicParam : SqlMapper.IDynamicParameters { protected readonly List
字典是这样的：
[Serializable] public class ERPDictionay : Dictionary { private string _currentPageParameterName = "@currentPage"; public string CurrentPageParameterName { get { return _currentPageParameterName; } set { _currentPageParameterName = value; } } private string _qtdItemsPageParameterName = "@qtdItemsPage"; public string QtdItemsPageParameterName { get { return _qtdItemsPageParameterName; } set { _qtdItemsPageParameterName = value; } } private string _totalItensDBParameterName = "@totalItensDB"; public string TotalItensDBParameterName { get { return _totalItensDBParameterName; } set { _totalItensDBParameterName = value; } } public int CurrentPage { get; set; } public int QtdItemsPage { get; set; } public int TotalItensDB { get; set; } public ERPDictionay() { } public ERPDictionay( int qtdItemsPage, int currentPage = 0, string currentPageParameterName = null, string qtdItemsPageParameterName = null, string totalItensDBParameterName = null) { QtdItemsPage = qtdItemsPage; CurrentPage = currentPage; if (!string.IsNullOrEmpty(currentPageParameterName)) _currentPageParameterName = currentPageParameterName; if(!string.IsNullOrEmpty(qtdItemsPageParameterName)) _qtdItemsPageParameterName = qtdItemsPageParameterName; if(!string.IsNullOrEmpty(totalItensDBParameterName)) _totalItensDBParameterName = totalItensDBParameterName; } }
如果从DynamicParameters派生自定义类并实现IDynamicParameters，则可以解决上述问题。
public class DynamicParametersWithTVP : Dapper.DynamicParameters, Dapper.SqlMapper.IDynamicParameters {
…..
我写了一个通用类，可以让你像这样调用一个proc：
var procParams = new DynamicParametersWithTVP(); procParams.Add("@Param1", someValue); procParams.Add("@Param2", someOtherValue); procParams.AddTVP("@TableParam1", "dbo.someTableType", someEnumberableListOfObject);