Commit 3ad72f42 authored by yangxiaodong's avatar yangxiaodong

update unit tests.

parent 7512c116
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Text; using System.Text;
using System.Threading.Tasks;
using Dapper; using Dapper;
using DotNetCore.CAP.Infrastructure; using DotNetCore.CAP.Infrastructure;
using DotNetCore.CAP.Models; using DotNetCore.CAP.Models;
...@@ -19,7 +20,7 @@ namespace DotNetCore.CAP.SqlServer.Test ...@@ -19,7 +20,7 @@ namespace DotNetCore.CAP.SqlServer.Test
} }
[Fact] [Fact]
public async void GetPublishedMessageAsync_Test() public async Task GetPublishedMessageAsync_Test()
{ {
var sql = "INSERT INTO [Cap].[Published]([Name],[Content],[Retries],[Added],[ExpiresAt],[StatusName]) OUTPUT INSERTED.Id VALUES(@Name,@Content,@Retries,@Added,@ExpiresAt,@StatusName);"; var sql = "INSERT INTO [Cap].[Published]([Name],[Content],[Retries],[Added],[ExpiresAt],[StatusName]) OUTPUT INSERTED.Id VALUES(@Name,@Content,@Retries,@Added,@ExpiresAt,@StatusName);";
var publishMessage = new CapPublishedMessage var publishMessage = new CapPublishedMessage
...@@ -40,7 +41,7 @@ namespace DotNetCore.CAP.SqlServer.Test ...@@ -40,7 +41,7 @@ namespace DotNetCore.CAP.SqlServer.Test
} }
[Fact] [Fact]
public async void FetchNextMessageAsync_Test() public async Task FetchNextMessageAsync_Test()
{ {
var sql = "INSERT INTO [Cap].[Queue]([MessageId],[MessageType]) VALUES(@MessageId,@MessageType);"; var sql = "INSERT INTO [Cap].[Queue]([MessageId],[MessageType]) VALUES(@MessageId,@MessageType);";
var queue = new CapQueue var queue = new CapQueue
...@@ -60,7 +61,7 @@ namespace DotNetCore.CAP.SqlServer.Test ...@@ -60,7 +61,7 @@ namespace DotNetCore.CAP.SqlServer.Test
} }
[Fact] [Fact]
public async void StoreReceivedMessageAsync_Test() public async Task StoreReceivedMessageAsync_Test()
{ {
var receivedMessage = new CapReceivedMessage var receivedMessage = new CapReceivedMessage
{ {
...@@ -83,7 +84,7 @@ namespace DotNetCore.CAP.SqlServer.Test ...@@ -83,7 +84,7 @@ namespace DotNetCore.CAP.SqlServer.Test
} }
[Fact] [Fact]
public async void GetReceivedMessageAsync_Test() public async Task GetReceivedMessageAsync_Test()
{ {
var sql = $@" var sql = $@"
...@@ -111,7 +112,7 @@ VALUES(@Name,@Group,@Content,@Retries,@Added,@ExpiresAt,@StatusName);"; ...@@ -111,7 +112,7 @@ VALUES(@Name,@Group,@Content,@Retries,@Added,@ExpiresAt,@StatusName);";
} }
[Fact] [Fact]
public async void GetNextReceviedMessageToBeEnqueuedAsync_Test() public async Task GetNextReceviedMessageToBeEnqueuedAsync_Test()
{ {
var receivedMessage = new CapReceivedMessage var receivedMessage = new CapReceivedMessage
{ {
......
...@@ -28,7 +28,7 @@ SELECT 'False'"; ...@@ -28,7 +28,7 @@ SELECT 'False'";
using (var connection = ConnectionUtil.CreateConnection()) using (var connection = ConnectionUtil.CreateConnection())
{ {
var sql = @" var sql = @"
IF OBJECT_ID(N'[CAP].[Published]',N'U') IS NOT NULL IF OBJECT_ID(N'[Cap].[Published]',N'U') IS NOT NULL
SELECT 'True' SELECT 'True'
ELSE ELSE
SELECT 'False'"; SELECT 'False'";
...@@ -43,7 +43,7 @@ SELECT 'False'"; ...@@ -43,7 +43,7 @@ SELECT 'False'";
using (var connection = ConnectionUtil.CreateConnection()) using (var connection = ConnectionUtil.CreateConnection())
{ {
var sql = @" var sql = @"
IF OBJECT_ID(N'[CAP].[Queue]',N'U') IS NOT NULL IF OBJECT_ID(N'[Cap].[Queue]',N'U') IS NOT NULL
SELECT 'True' SELECT 'True'
ELSE ELSE
SELECT 'False'"; SELECT 'False'";
...@@ -58,7 +58,7 @@ SELECT 'False'"; ...@@ -58,7 +58,7 @@ SELECT 'False'";
using (var connection = ConnectionUtil.CreateConnection()) using (var connection = ConnectionUtil.CreateConnection())
{ {
var sql = @" var sql = @"
IF OBJECT_ID(N'[CAP].[Received]',N'U') IS NOT NULL IF OBJECT_ID(N'[Cap].[Received]',N'U') IS NOT NULL
SELECT 'True' SELECT 'True'
ELSE ELSE
SELECT 'False'"; SELECT 'False'";
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment