Identity数据库与DateDatabase跨项目配置及操作问题咨询

1. 数据库模型的存放位置 #

• Identity相关模型（如UserIdentityModel）：放在Identity数据库所在项目中。这是身份认证服务的核心模型，属于身份域的边界，保持身份服务的独立性，避免与业务逻辑耦合。
• 业务模型（如UserModel）：放在DateDatabase业务项目中。业务数据属于业务域，与身份数据解耦，同时因为业务项目已引用Identity项目，不会出现循环引用问题。

2. 同时向两个数据库写入数据的实现 #

通过在业务项目中封装统一的注册服务，注入身份认证所需的UserManager<IdentityUser>（或IdentityDbContext）和业务库的DateDbContext，在同一个方法中完成两个库的数据写入，同时建议使用事务保证数据一致性。

实现步骤： #

1. 定义包含身份信息和业务信息的DTO：

public class RegisterDto
{
    public string Email { get; set; }
    public string UserName { get; set; }
    public string Password { get; set; }
    public string FirstName { get; set; }
    public string LastName { get; set; }
    public string? PhotoUrl { get; set; }
}

2. 创建注册API接口，完成双库写入：

[ApiController]
[Route("api/[controller]")]
public class AuthController : ControllerBase
{
    private readonly UserManager<IdentityUser> _userManager;
    private readonly DateDbContext _dateDbContext;

    public AuthController(UserManager<IdentityUser> userManager, DateDbContext dateDbContext)
    {
        _userManager = userManager;
        _dateDbContext = dateDbContext;
    }

    [HttpPost("register")]
    public async Task<IActionResult> Register(RegisterDto dto)
    {
        // 1. 向Identity库写入用户身份信息
        var identityUser = new IdentityUser
        {
            UserName = dto.UserName,
            Email = dto.Email
        };
        var identityResult = await _userManager.CreateAsync(identityUser, dto.Password);
        if (!identityResult.Succeeded)
        {
            return BadRequest(identityResult.Errors);
        }

        // 2. 向业务库写入用户业务信息
        var businessUser = new UserModel
        {
            FirstName = dto.FirstName,
            LastName = dto.LastName,
            PhotoUrl = dto.PhotoUrl,
            CreatedAt = DateTime.UtcNow
        };
        _dateDbContext.UserModels.Add(businessUser);
        await _dateDbContext.SaveChangesAsync();

        return Ok("注册成功");
    }
}

注：如果需要强一致性，可使用分布式事务（如SQL Server跨库事务、TransactionScope），确保两个库的写入要么同时成功，要么同时回滚。在Swagger中直接调用该register接口，点击执行即可完成双库数据写入。

3. 从Identity数据库查询特定用户 #

利用业务项目已引用Identity项目的优势，直接注入UserManager<IdentityUser>或IdentityDbContext进行查询：

方法1：使用UserManager（符合Identity框架设计，推荐） #

[HttpGet("user/{userName}")]
public async Task<IActionResult> GetUser(string userName)
{
    var user = await _userManager.FindByNameAsync(userName);
    if (user == null)
    {
        return NotFound("用户不存在");
    }
    return Ok(new 
    {
        user.Id,
        user.UserName,
        user.Email,
        user.EmailConfirmed
    });
}

方法2：直接操作IdentityDbContext #

private readonly IdentityDbContext _identityDbContext;

// 构造函数注入IdentityDbContext
public AuthController(IdentityDbContext identityDbContext, ...)
{
    _identityDbContext = identityDbContext;
}

[HttpGet("user/{userName}")]
public IActionResult GetUser(string userName)
{
    var user = _identityDbContext.Users.FirstOrDefault(u => u.UserName == userName);
    if (user == null)
    {
        return NotFound("用户不存在");
    }
    return Ok(user);
}

附相关模型代码 #

UserModel（DateDatabase业务库）

public class UserModel
{
    public string? FirstName { get; set; }
    public string? LastName { get; set; }
    public string? PhotoUrl { get; set; }
    public DateTime CreatedAt { get; set; }
    public DateTime? UpdatedAt { get; set; }
}

UserIdentityModel（Identity身份库）

标准Identity用户模型，核心字段包括：

• Id：用户唯一标识
• UserName：用户名
• Email：邮箱地址
• PasswordHash：密码哈希值
• EmailConfirmed：邮箱是否已验证
• PhoneNumber：手机号
• PhoneNumberConfirmed：手机号是否已验证等

内容的提问来源于stack exchange，提问作者Majkelele