我正在做一个具有数据访问层 (DAL) 的 asp.net mvc 应用程序。完成了 90% 的数据库 CRUD 代码后,我问自己是否需要业务层。
但是我应该放什么?例如,我在 DAL 中的所有 CRUD 方法都不是一个 sql 表上的单一选择。大多数时候我会做很多连接 + sql 聚合函数。只是提到我使用 ADO.NET ,没有存储过程/触发器。
然后我又问自己这种方法是否属于业务层:
/// <summary>
/// Creates a testplan with all teststeps and their default values for a certain template
/// </summary>
/// <param name="testplan"></param>
/// <returns>true if transaction was successfull else false</returns>
public void CreateTestplan(Testplan testplan)
{
try
{
using (var con = new SqlConnection(_connectionString))
using (var trans = new TransactionScope())
{
con.Open();
_testplanDataProvider.AddTestplan(testplan,con);
_testplanDataProvider.CreateTeststepsForTestplan(testplan.Id, testplan.TemplateId,con);
trans.Complete();
}
}
catch (SqlException ex)
{
ExceptionManager.HandleException(ex);
}
}
这个方法实际上调用了 DAL 中的另外两个方法。
现在我问自己,为什么要引入一个额外的业务层,因为我可以将 CreateTestplan 方法也放在 TestplanDataProvider 类中,其中包含来自两个方法 AddTestplan + CreateTeststepsForTestplan 的所有代码。
你怎么看?这是一个好方法吗?
我真的问这个是因为在我看来 CreateTestplan 方法只包含数据访问逻辑。
更新:
public void AddTestplan(Testplan testplan, SqlConnection con)
{
using (var cmd = new SqlCommand("INSERT INTO TESTPLAN (ReleaseId,TemplateId,CreatedAt,UserId,Name,Duration) VALUES (@ReleaseId,@TemplateId,@CreatedAt,@UserId,@Name,@Duration);Select Scope_Identity();", con))
{
var p1 = new SqlParameter("@ReleaseId", testplan.ReleaseId);
var p2 = new SqlParameter("@TemplateId", testplan.TemplateId);
var p3 = new SqlParameter("@CreatedAt", testplan.CreatedAt);
var p4 = new SqlParameter("@UserId", testplan.UserId);
var p5 = new SqlParameter("@Name", testplan.Name);
var p6 = new SqlParameter("@Duration", testplan.Duration);
cmd.Parameters.AddRange(new[] { p1, p2, p3, p4, p5, p6 });
testplan.Id = Convert.ToInt32(cmd.ExecuteScalar());
}
}
public void CreateTeststepsForTestplan(int testplanId, int templateId, SqlConnection con)
{
var teststeps = new List<Teststep>();
using (var selectCMD = new SqlCommand("SELECT ts.TeststepId, MAX(ts.CreatedAt)FROM Teststep ts INNER JOIN Unit u ON ts.UnitId = u.UnitId Where u.TemplateId = @TemplateId Group by TeststepId", con))
{
var p = new SqlParameter("@TemplateId", templateId);
selectCMD.Parameters.Add(p);
using (var reader = selectCMD.ExecuteReader())
{
Teststep teststep = null;
while (reader.Read())
{
teststep = new Teststep
{
Id = Convert.ToInt32(reader["TeststepId"]),
CreatedAt = Convert.ToDateTime(reader["CreatedAt"]),
};
teststeps.Add(teststep);
}
}
}
using (var insertCMD = new SqlCommand("INSERT INTO TestplanTeststep (TestplanId,TeststepId,TestState,ErrorText) VALUES (@TestplanId, @TeststepId, @TestState, @ErrorText)", con))
{
var p1 = new SqlParameter("@TeststepId", SqlDbType.Int);
var p2 = new SqlParameter("@CreatedAt", SqlDbType.DateTime);
var p3 = new SqlParameter("@TestplanId", testplanId);
var p4 = new SqlParameter("@ErrorText", DBNull.Value);
var p5 = new SqlParameter("@ErrorScreenshot", DBNull.Value);
var p6 = new SqlParameter("@TestState", (int)Teststep.TeststepTestState.Untested);
insertCMD.Parameters.AddRange(new[] { p1, p2, p3, p4, p5 });
foreach (Teststep step in teststeps)
{
p1.Value = step.Id;
p2.Value = step.CreatedAt;
insertCMD.ExecuteNonQuery();
}
}
}