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が最初に呼び出され、ユーザーのデータがデータベースに挿入され、影響を受ける行が 0 ではなく 1 として返されます。データベースの Users テーブルを右クリックして [データの表示] をクリックすると、データが表示されません。

このRetrieveUserIdメソッドは、データの挿入後に SQL Server によって自動的に生成されたユーザー ID を取得するために呼び出されます。行は、retrieveCmd.ExecuteReader()タイムアウトが発生する場所です。dbo.SQL ステートメントの前にプレフィックスを試しましたがUsers、どちらも機能しませんでした。

ExecuteReaderとメソッドの非同期バージョンも試しましたが、うまくいきExecuteNonQueryませんでした。次に何をすべきか迷っています。どんな助けでも大歓迎です。

4

0 に答える 0