我正在使用 .NET Core 并试图找出 SQL Server localdb 不工作的原因。我正在使用 Dapper 连接到数据库,并使用断点检查所有数据是否都在那里。尝试ExecuteReader
从类中调用方法时出现此错误DbCommand
。
我的 SQL Server 连接字符串是:
"DefaultConnection": "Data Source=(localdb)\\MSSQLLocalDB;Initial Catalog=PostStackDatabaseV2;Integrated Security=False;Connect Timeout=60;Encrypt=False;TrustServerCertificate=True;ApplicationIntent=ReadWrite;MultiSubnetFailover=False"
我使用 localdb SQL Server 数据库并尝试使用 SQL Server Management Studio 连接到它,并且成功。我注册用户的代码在这里:
public int RegisterUser(string connectionStr, string name, string email, string password)
{
using (IDbConnection conn = new SqlConnection(connectionStr))
{
// hash password here before it goes into the database
var passwordHasher = new PasswordHasher();
string hashedPassword = passwordHasher.HashPassword(password);
var isAdmin = 0;
DateTime currentTime = DateTime.Now;
conn.Open();
using (var transaction = conn.BeginTransaction())
{
using (DbCommand registerCommand = (DbCommand)conn.CreateCommand())
{
try
{
registerCommand.Transaction = (DbTransaction)transaction;
registerCommand.CommandText = "INSERT INTO Users VALUES (@UserName, @UserEmail, @UserPassword, @CreatedAt, @Admin)";
registerCommand.Connection = (DbConnection)conn;
var firstNameParam = registerCommand.CreateParameter();
firstNameParam.ParameterName = "@UserName";
firstNameParam.Value = name;
registerCommand.Parameters.Add(firstNameParam);
var emailParam = registerCommand.CreateParameter();
emailParam.ParameterName = "@UserEmail";
emailParam.Value = email;
registerCommand.Parameters.Add(emailParam);
var passwordParam = registerCommand.CreateParameter();
passwordParam.ParameterName = "@UserPassword";
passwordParam.Value = password;
registerCommand.Parameters.Add(passwordParam);
var createdAtParam = registerCommand.CreateParameter();
createdAtParam.ParameterName = "@CreatedAt";
createdAtParam.Value = currentTime;
registerCommand.Parameters.Add(createdAtParam);
var adminParam = registerCommand.CreateParameter();
adminParam.ParameterName = "@Admin";
adminParam.Value = isAdmin;
registerCommand.Parameters.Add(adminParam);
int rowsAffected = registerCommand.ExecuteNonQuery();
// conn.Close();
Console.WriteLine(rowsAffected);
int userId = RetrieveUserId(email, connectionStr);
return userId;
}
catch
{
transaction.Rollback();
conn.Close();
throw;
}
}
}
}
}
private int RetrieveUserId(string userEmail, string connectionStr)
{
using (DbConnection conn = new SqlConnection(connectionStr))
{
conn.Open();
using (var transaction = conn.BeginTransaction())
{
using (var retrieveCmd = conn.CreateCommand())
{
retrieveCmd.Connection = conn;
retrieveCmd.Transaction = transaction;
retrieveCmd.CommandText = "SELECT Id FROM Users WHERE Email = @UserEmail";
retrieveCmd.CommandType = CommandType.Text;
retrieveCmd.Parameters.Add(new SqlParameter("@UserEmail", userEmail));
try
{
var reader = retrieveCmd.ExecuteReader(CommandBehavior.CloseConnection);
if (reader.Read())
{
string userIdStr = reader.GetValue(0).ToString();
int userId = int.Parse(userIdStr);
if (userId != -1)
{
// conn.Close();
return userId;
}
else
{
// conn.Close();
return -1;
}
}
else
{
return -1;
}
}
catch(DbException err)
{
Console.WriteLine("DbException.GetType: {0}", err.GetType());
Console.WriteLine("DbException.Source: {0}", err.Source);
Console.WriteLine("DbException.ErrorCode: {0}", err.ErrorCode);
Console.WriteLine("DbException.Message: {0}", err.Message);
return -1;
}
catch(Exception e)
{
Console.WriteLine(e.Message);
return -1;
}
}
}
}
}
RegisterUser
首先调用它将用户的数据插入数据库,受影响的行返回为 1 而不是 0。当我右键单击数据库用户表并单击“查看数据”时,我看不到任何数据。
在插入数据后,调用该RetrieveUserId
方法检索 SQL Server 自动生成的用户 ID。该retrieveCmd.ExecuteReader()
行是超时发生的地方。我在 SQL 语句中尝试了dbo.
前面的前缀,Users
它也不起作用。
我还尝试了ExecuteReader
andExecuteNonQuery
方法的异步版本,但没有奏效。我迷失了下一步该做什么任何帮助将不胜感激。