0

我正在使用 .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它也不起作用。

我还尝试了ExecuteReaderandExecuteNonQuery方法的异步版本,但没有奏效。我迷失了下一步该做什么任何帮助将不胜感激。

4

0 回答 0