本文整理汇总了C#中SqlQuery类的典型用法代码示例。如果您正苦于以下问题：C# SqlQuery类的具体用法？C# SqlQuery怎么用？C# SqlQuery使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
SqlQuery类属于命名空间，在下文中一共展示了SqlQuery类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的C#代码示例。
示例1: BuildCommandForSqlQueryWithSqlText
public void BuildCommandForSqlQueryWithSqlText()
{
var command = new OleDbCommand();
var sqlQuery = new SqlQuery(
"SELECT * FROM Table WHERE Table.Id = ? AND Table.Value1 = ? AND Table.Value2 = ?",
100, "hello", null);
var mockDbDriver = new Mock<DbDriver>(SqlCharacters.Empty);
mockDbDriver.CallBase = true;
mockDbDriver.Object.BuildCommand(command, sqlQuery);
Assert.Equal(sqlQuery.CommandText, command.CommandText);
Assert.Equal(CommandType.Text, command.CommandType);
Assert.Equal(3, command.Parameters.Count);
var parameter1 = (IDataParameter)command.Parameters[0];
Assert.Equal(DbType.Int32, parameter1.DbType);
Assert.Equal(ParameterDirection.Input, parameter1.Direction);
Assert.Equal("Parameter0", parameter1.ParameterName);
Assert.Equal(sqlQuery.Arguments[0].Value, parameter1.Value);
var parameter2 = (IDataParameter)command.Parameters[1];
Assert.Equal(DbType.String, parameter2.DbType);
Assert.Equal(ParameterDirection.Input, parameter2.Direction);
Assert.Equal("Parameter1", parameter2.ParameterName);
Assert.Equal(sqlQuery.Arguments[1].Value, parameter2.Value);
var parameter3 = (IDataParameter)command.Parameters[2];
Assert.Equal(default(DbType), parameter3.DbType);
Assert.Equal(ParameterDirection.Input, parameter3.Direction);
Assert.Equal("Parameter2", parameter3.ParameterName);
Assert.Equal(DBNull.Value, parameter3.Value);
}
开发者ID:natarajanmca11，项目名称:MicroLite，代码行数:34，代码来源:DbDriverTests.cs
示例2: BuildCommandForSqlQueryWithStoredProcedureWithParameters
public void BuildCommandForSqlQueryWithStoredProcedureWithParameters()
{
var command = new OleDbCommand();
var sqlQuery = new SqlQuery(
"SELECT GetTableContents (@identifier, @Cust_Name)",
100, "hello");
var dbDriver = new PostgreSqlDbDriver();
dbDriver.BuildCommand(command, sqlQuery);
// The command text should only contain the stored procedure name.
Assert.Equal("GetTableContents", command.CommandText);
Assert.Equal(CommandType.StoredProcedure, command.CommandType);
Assert.Equal(2, command.Parameters.Count);
var parameter1 = (IDataParameter)command.Parameters[0];
Assert.Equal(DbType.Int32, parameter1.DbType);
Assert.Equal(ParameterDirection.Input, parameter1.Direction);
Assert.Equal("@identifier", parameter1.ParameterName);
Assert.Equal(sqlQuery.Arguments[0].Value, parameter1.Value);
var parameter2 = (IDataParameter)command.Parameters[1];
Assert.Equal(DbType.String, parameter2.DbType);
Assert.Equal(ParameterDirection.Input, parameter2.Direction);
Assert.Equal("@Cust_Name", parameter2.ParameterName);
Assert.Equal(sqlQuery.Arguments[1].Value, parameter2.Value);
}
开发者ID:natarajanmca11，项目名称:MicroLite，代码行数:28，代码来源:PostgreSqlDbDriverTests.cs
示例3: PageQuery
public override SqlQuery PageQuery(SqlQuery sqlQuery, PagingOptions pagingOptions)
{
if (sqlQuery == null)
{
throw new ArgumentNullException("sqlQuery");
}
var arguments = new object[sqlQuery.Arguments.Count + 2];
Array.Copy(sqlQuery.ArgumentsArray, 0, arguments, 0, sqlQuery.Arguments.Count);
arguments[arguments.Length - 2] = pagingOptions.Offset + 1;
arguments[arguments.Length - 1] = pagingOptions.Offset + pagingOptions.Count;
var sqlString = SqlString.Parse(sqlQuery.CommandText, Clauses.Select | Clauses.From | Clauses.Where | Clauses.OrderBy);
var qualifiedTableName = sqlString.From;
var position = qualifiedTableName.LastIndexOf('.') + 1;
var tableName = position > 0 ? qualifiedTableName.Substring(position, qualifiedTableName.Length - position) : qualifiedTableName;
var whereClause = !string.IsNullOrEmpty(sqlString.Where) ? " WHERE " + sqlString.Where : string.Empty;
var orderByClause = !string.IsNullOrEmpty(sqlString.OrderBy) ? sqlString.OrderBy : "(SELECT NULL)";
var stringBuilder = new StringBuilder(sqlQuery.CommandText.Length * 2)
.Append("SELECT ")
.Append(sqlString.Select)
.Append(" FROM")
.AppendFormat(CultureInfo.InvariantCulture, " (SELECT {0},ROW_NUMBER() OVER(ORDER BY {1}) AS RowNumber FROM {2}{3}) AS {4}", sqlString.Select, orderByClause, qualifiedTableName, whereClause, tableName)
.AppendFormat(CultureInfo.InvariantCulture, " WHERE (RowNumber >= {0} AND RowNumber <= {1})", this.SqlCharacters.GetParameterName(arguments.Length - 2), this.SqlCharacters.GetParameterName(arguments.Length - 1));
return new SqlQuery(stringBuilder.ToString(), arguments);
}
开发者ID:rubenalves，项目名称:MicroLite，代码行数:30，代码来源:MsSqlDialect.cs
示例4: WhenCallingBindOrderBy
public WhenCallingBindOrderBy()
{
this.sqlQuery = OrderByBinder.BindOrderBy(
new OrderByQueryOption("$orderby=Status desc,Name"),
ObjectInfo.For(typeof(Customer)),
SqlBuilder.Select("*").From(typeof(Customer))).ToSqlQuery();
}
开发者ID:TrevorPilley，项目名称:MicroLite.Extensions.WebApi，代码行数:7，代码来源:OrderByBinderTests.cs
示例5: GetCommentsBySearch
public override CommentCollection GetCommentsBySearch(int operatorID, Guid[] excludeRoleIDs, AdminCommentFilter filter, int pageNumber)
{
using (SqlQuery query = new SqlQuery())
{
string conditions = BuildConditionsByFilter(query, filter, false, operatorID, excludeRoleIDs);
query.Pager.TableName = "[bx_Comments]";
query.Pager.SortField = filter.Order.ToString();
query.Pager.IsDesc = filter.IsDesc;
query.Pager.PageNumber = pageNumber;
query.Pager.PageSize = filter.PageSize;
query.Pager.SelectCount = true;
query.Pager.Condition = conditions.ToString();
using (XSqlDataReader reader = query.ExecuteReader())
{
CommentCollection comments = new CommentCollection(reader);
if (reader.NextResult())
{
if (reader.Read())
{
comments.TotalRecords = reader.Get<int>(0);
}
}
return comments;
}
}
}
开发者ID:huchao007，项目名称:bbsmax，代码行数:31，代码来源:CommentDao.cs
示例6: ParseMethodCall
protected override IParseContext ParseMethodCall(ExpressionParser parser, IParseContext parent, MethodCallExpression methodCall, SqlQuery sqlQuery)
{
var sequence = parser.ParseSequence(parent, methodCall.Arguments[0], sqlQuery);
var defaultValue = methodCall.Arguments.Count == 1 ? null : methodCall.Arguments[1].Unwrap();
return new DefaultIfEmptyContext(sequence, defaultValue);
}
开发者ID:Firebie，项目名称:ItemsUsage，代码行数:7，代码来源:DefaultIfEmptyParser.cs
示例7: Test
public void Test()
{
var da = new SqlQuery();
var p = (Person)da.SelectByKey(typeof(Person), 1);
Assert.AreEqual("Pupkin", p.Name.LastName);
}
开发者ID:x64，项目名称:bltoolkit，代码行数:7，代码来源:SqlTest.cs
示例8: GetPropLogs
public override PropLogCollection GetPropLogs(int userID, PropLogType type, int pageNumber, int pageSize)
{
using(SqlQuery query = new SqlQuery())
{
query.Pager.TableName = "bx_PropLogs";
query.Pager.SortField = "PropLogID";
query.Pager.PageNumber = pageNumber;
query.Pager.PageSize = pageSize;
query.Pager.SelectCount = true;
query.Pager.Condition = "UserID = @UserID";
query.CreateParameter<int>("@UserID", userID, SqlDbType.Int);
if(type != PropLogType.All)
{
query.CreateParameter<PropLogType>("@Type", type, SqlDbType.TinyInt);
query.Pager.Condition += " AND Type = @Type";
}
using (XSqlDataReader reader = query.ExecuteReader())
{
PropLogCollection result = new PropLogCollection(reader);
if(reader.NextResult() && reader.Read())
result.TotalRecords = reader.Get<int>(0);
return result;
}
}
}
开发者ID:huchao007，项目名称:bbsmax，代码行数:30，代码来源:PropDao.cs
示例9: ConstructorSetsArgumentsToEmptyArrayIfNoneSpecified
public void ConstructorSetsArgumentsToEmptyArrayIfNoneSpecified()
{
var sqlQuery = new SqlQuery(string.Empty);
Assert.NotNull(sqlQuery.Arguments);
Assert.Empty(sqlQuery.Arguments);
}
开发者ID:rubenalves，项目名称:MicroLite，代码行数:7，代码来源:SqlQueryTests.cs
示例10: GetLastChatMessages
public override ChatMessageCollection GetLastChatMessages(int userID, int targetUserID, int lastMessageID, int MessageCount)
{
ChatMessageCollection result;
using (SqlQuery query = new SqlQuery())
{
query.CommandText = "bx_Chat_GetLastMessages";
query.CommandType = CommandType.StoredProcedure;
query.CreateParameter<int>("@UserID", userID, SqlDbType.Int);
query.CreateParameter<int>("@TargetUserID", targetUserID, SqlDbType.Int);
query.CreateParameter<int>("@LastMessageID", lastMessageID, SqlDbType.Int);
using (XSqlDataReader reader = query.ExecuteReader())
{
result = new ChatMessageCollection();
while (reader.Read())
{
result.Insert(0, new ChatMessage(reader));
}
}
return result;
}
}
开发者ID:huchao007，项目名称:bbsmax，代码行数:25，代码来源:ChatDao.cs
示例11: DeletePropLogs
public override void DeletePropLogs(JobDataClearMode clearMode, DateTime dateTime, int saveRows)
{
using (SqlQuery query = new SqlQuery())
{
switch(clearMode)
{
case JobDataClearMode.ClearByDay:
query.CommandText = "DELETE FROM bx_PropLogs WHERE CreateDate <= @Time;";
query.CreateParameter<DateTime>("@Time", dateTime, SqlDbType.DateTime);
break;
case JobDataClearMode.ClearByRows:
query.CommandText = "DELETE FROM bx_PropLogs WHERE PropLogID < (SELECT MIN(O.PropLogID) FROM (SELECT TOP(@TopCount) PropLogID FROM bx_PropLogs ORDER BY PropLogID DESC) AS O)";
query.CreateTopParameter("@TopCount", saveRows);
break;
case JobDataClearMode.CombinMode:
query.CommandText = "DELETE FROM bx_PropLogs WHERE PropLogID < (SELECT MIN(O.PropLogID) FROM (SELECT TOP(@TopCount) PropLogID FROM bx_PropLogs ORDER BY PropLogID DESC) AS O) AND CreateDate >= @Time";
query.CreateTopParameter("@TopCount", saveRows);
query.CreateParameter<DateTime>("@Time", dateTime, SqlDbType.DateTime);
break;
}
query.ExecuteNonQuery();
}
}
开发者ID:huchao007，项目名称:bbsmax，代码行数:28，代码来源:PropDao.cs
示例12: GetWebsites
public override List<Website> GetWebsites(int pageSize, int pageNumber, out int totalCount)
{
using (SqlQuery query = new SqlQuery())
{
query.Pager.TableName = "Chinaz_Websites";
query.Pager.PageNumber = pageNumber;
query.Pager.PageSize = pageSize;
query.Pager.PrimaryKey = "WebsiteID";
query.Pager.SortField = "WebsiteID";
query.Pager.SelectCount = true;
query.Pager.IsDesc = true;
using (XSqlDataReader reader = query.ExecuteReader())
{
totalCount = 0;
List<Website> results = new List<Website>();
while (reader.Next)
{
results.Add(new Website(reader));
}
if (reader.NextResult())
while (reader.Next)
totalCount = reader.Get<int>(00);
return results;
}
}
}
开发者ID:huchao007，项目名称:bbsmax，代码行数:27，代码来源:WebsiteDao.cs
示例13: FromQuery
public FromQuery(SqlQuery oQuery, String sName)
: base()
{
_Cmd = oQuery.GetCommand();
Name = sName;
Provider = _Cmd.Provider;
Columns = oQuery.SelectColumns.Select((X) =>
(IColumn)new DatabaseColumn(X.Name, this)
{
DataType = X.DataType,
DefaultSetting = X.DefaultSetting,
ForeignKeyTo = X.ForeignKeyTo,
IsForeignKey = X.IsForeignKey,
FriendlyName = X.FriendlyName
}).ToList();
foreach (Aggregate oAggregate in oQuery.Aggregates)
{
bool hasAlais = !String.IsNullOrEmpty(oAggregate.Alias);
Columns.Add(new DatabaseColumn(hasAlais ? oAggregate.Alias : oAggregate.ColumnName, this)
{
DataType = oAggregate.GetDataType()
});
}
}
开发者ID:kccarter，项目名称:SubSonic-3.0，代码行数:27，代码来源:FromQuery.cs
示例14: BuildCommandForSqlQueryWithSqlTextWhichUsesSameParameterTwice
public void BuildCommandForSqlQueryWithSqlTextWhichUsesSameParameterTwice()
{
var sqlQuery = new SqlQuery(
"SELECT * FROM [Table] WHERE [Table].[Id] = @p0 AND [Table].[Value1] = @p1 OR @p1 IS NULL",
100, "hello");
var command = new OleDbCommand();
var mockDbDriver = new Mock<DbDriver>(SqlCharacters.Empty);
mockDbDriver.CallBase = true;
mockDbDriver.Object.BuildCommand(command, sqlQuery);
Assert.Equal(sqlQuery.CommandText, command.CommandText);
Assert.Equal(CommandType.Text, command.CommandType);
Assert.Equal(2, command.Parameters.Count);
var parameter1 = (IDataParameter)command.Parameters[0];
Assert.Equal(DbType.Int32, parameter1.DbType);
Assert.Equal(ParameterDirection.Input, parameter1.Direction);
Assert.Equal("@p0", parameter1.ParameterName);
Assert.Equal(sqlQuery.Arguments[0].Value, parameter1.Value);
var parameter2 = (IDataParameter)command.Parameters[1];
Assert.Equal(DbType.String, parameter2.DbType);
Assert.Equal(ParameterDirection.Input, parameter2.Direction);
Assert.Equal("@p1", parameter2.ParameterName);
Assert.Equal(sqlQuery.Arguments[1].Value, parameter2.Value);
}
开发者ID:natarajanmca11，项目名称:MicroLite，代码行数:28，代码来源:DbDriverTests.cs
示例15: findUsersByNameAndProjection
public User[] findUsersByNameAndProjection()
{
SqlQuery<User> query = new SqlQuery<User>( "Name = ?"){Projections = new []{"Name"}};
query.SetParameter (1, "John Dow");
return proxy.ReadMultiple<User>(query);
}
开发者ID:Gigaspaces，项目名称:xapnet-tutorial，代码行数:7，代码来源:QueryService.cs
示例16: EqualsReturnsFalseIfCommandTextMatchesButArgumentsDiffer
public void EqualsReturnsFalseIfCommandTextMatchesButArgumentsDiffer()
{
var sqlQuery1 = new SqlQuery("SELECT * FROM Table WHERE Id = @p0", 10);
var sqlQuery2 = new SqlQuery("SELECT * FROM Table WHERE Id = @p0", 35);
Assert.False(sqlQuery1.Equals(sqlQuery2));
}
开发者ID:rubenalves，项目名称:MicroLite，代码行数:7，代码来源:SqlQueryTests.cs
示例17: findUsersByRegularExpression
public User[] findUsersByRegularExpression()
{
// Match all entries of type User that have a name that starts with J or
// R:
SqlQuery<User> query = new SqlQuery<User>( "Name rlike '(J|R).*'");
return proxy.ReadMultiple<User>(query);
}
开发者ID:Gigaspaces，项目名称:xapnet-tutorial，代码行数:7，代码来源:QueryService.cs
示例18: EqualsReturnsTrueIfCommandTextMatchesAndArgumentsMatch
public void EqualsReturnsTrueIfCommandTextMatchesAndArgumentsMatch()
{
var sqlQuery1 = new SqlQuery("SELECT * FROM Table WHERE Id = @p0", 10);
var sqlQuery2 = new SqlQuery("SELECT * FROM Table WHERE Id = @p0", 10);
Assert.True(sqlQuery1.Equals(sqlQuery2));
}
开发者ID:rubenalves，项目名称:MicroLite，代码行数:7，代码来源:SqlQueryTests.cs
示例19: CreateClub
public override CreateClubResult CreateClub(int operatorID, int categoryID, string clubName, bool isApproved, string operatorIP, out int newClubID)
{
using (SqlQuery db = new SqlQuery())
{
db.CommandText = "bx_Club_CreateClub";
db.CommandType = System.Data.CommandType.StoredProcedure;
db.CreateParameter<int>("@UserID", operatorID, SqlDbType.Int);
db.CreateParameter<int>("@CategoryID", categoryID, SqlDbType.Int);
db.CreateParameter<bool>("@IsApproved", isApproved, SqlDbType.Bit);
db.CreateParameter<string>("@CreateIP", operatorIP, SqlDbType.VarChar, 50);
db.CreateParameter<string>("@Name", clubName, SqlDbType.NVarChar, 50);
SqlParameter newID = db.CreateParameter<int>("@NewClubID", SqlDbType.Int, ParameterDirection.Output);
SqlParameter result = db.CreateParameter<int>("@Result", SqlDbType.Int, ParameterDirection.ReturnValue);
db.ExecuteNonQuery();
switch ((int)result.Value)
{
case 0:
newClubID = 0;
return CreateClubResult.HasSameNameClub;
default:
newClubID = (int)newID.Value;
return CreateClubResult.Succeed;
}
}
}
开发者ID:huchao007，项目名称:bbsmax，代码行数:31，代码来源:ClubDao.cs
示例20: AddFriendGroups
public override int AddFriendGroups(int userID, List<KeyValuePair<int, string>> friendGroup)
{
using (SqlQuery query = new SqlQuery())
{
StringBuilder sbSql = new StringBuilder();
int i=0;
string deleteExistGroupSql = "DELETE FROM bx_FriendGroups WHERE GroupID IN(";
foreach (KeyValuePair<int, string> group in friendGroup)
{
string groupName = "@GroupName_"+i;
string groupID = "@GroupID_"+i;
sbSql.AppendFormat(" INSERT INTO bx_FriendGroups( GroupID, GroupName, UserID) VALUES({0},{1},@UserID);", groupID, groupName);
deleteExistGroupSql = string.Concat(deleteExistGroupSql,group.Key, ",");
query.CreateParameter<int>(groupID, group.Key, SqlDbType.Int);
query.CreateParameter<string>(groupName, group.Value, SqlDbType.NVarChar, 50);
i++;
}
deleteExistGroupSql = deleteExistGroupSql.TrimEnd(',') + ");";
sbSql.Insert(0, deleteExistGroupSql); //删除已经存在的相同ID的好友分组--
query.CommandText =sbSql.ToString();
query.CreateParameter<int>("@UserID", userID, SqlDbType.Int);
return query.ExecuteNonQuery();
}
}
开发者ID:huchao007，项目名称:bbsmax，代码行数:29，代码来源:FriendDao.cs
注：本文中的SqlQuery类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论