使用 jdbcTemplate 和 DAO Layer 在 jUnit 中测试删除方法

我正在尝试测试我的删除方法，但我不知道该怎么做，我尝试在我的测试删除方法中调用我的 searchByID 与我删除的用户的 id 创建一个空变量，然后使用assertNull

喜欢这个：

    @Test
    public void deleteUser() 
    {
        userDAO.deleteUserById(3);
        User nullUser  =  userDAO.searchUserById(3);
        assertNull(nullUser);
    }

但这给了我这个错误：

expected null but was domain.User@c506pb

我尝试使用异常方法，因为我可以在输出中发现该代码生成java.sql.SQLException: ORA-01403: no data found 我试过这样：

    @Test(expected=SQLException.class)
    public void deleteUser() 
    {
         userDAO.deleteUserById(3);
        Usuario usuarioVacio  =  usuarioDAO.buscarUsuarioPorId(3);
    }

但这给了我这个错误：

Expected exception: java.sql.SQLException
java.lang.AssertionError

这是我的删除方法实现

@Override
public void deleteUserById(int idUser)
{
    Connection connection = null;
    try {
        String storedProcedure =  "{ call deleteUserById(?) }";
        connection  =  jdbcTemplate.getDataSource().getConnection();
        CallableStatement callableStatement = connection.prepareCall(storedProcedureBorrarUSuario);
        callableStatement.setInt(1, idUser);
        callableStatement.executeQuery();
    } 
    catch (SQLException ex) 
    {
        ex.printStackTrace();
    }
    finally 
    {
        if(connection != null)
        try 
        {
            connection.close();
        } 
        catch (SQLException e) 
        {
            e.printStackTrace();
        }
    }
}

该方法有效，因为它删除了正确的用户，我想使用两种方法异常方法和另一种方法，但我不知道为什么不起作用

编辑：

这是我的搜索ById方法

@Override
    public Usuario buscarUsuarioPorId(int userId) 
    {
        User user=  new  User();
        Connection connection = null;
        try {
            String storedProcedureInfoUsuario  =  "{ call searchUserById(?, ?, ?, ?, ?) }";
            connection  =  jdbcTemplate.getDataSource().getConnection();
            CallableStatement callableStatement = connection.prepareCall(storedProcedureInfoUsuario);
            callableStatement.setInt(1, idUsuario);
            callableStatement.registerOutParameter(2, Types.VARCHAR);
            callableStatement.registerOutParameter(3, Types.VARCHAR);
            callableStatement.registerOutParameter(4, Types.VARCHAR);
            callableStatement.registerOutParameter(5, Types.VARCHAR);
            callableStatement.executeQuery();
            //
            user.setName(callableStatement.getString(2));
            user.setLastName(callableStatement.getString(3));
            user.setEmail(callableStatement.getString(4));
            user.setState(callableStatement.getString(5));
        } 
        catch (SQLException ex) 
        {
//          Logger.getLogger(UsuarioDAOImplementacion.class.getName()).log(Level.SEVERE, null, ex);
            ex.printStackTrace();
        }
        finally 
        {
            if(connection != null)
            try 
            {
                connection.close();
            } 
            catch (SQLException e) 
            {
                e.printStackTrace();
            }
        }
        return usuario;
    }

这是我的PL/SQL搜索ById

CREATE OR REPLACE PROCEDURE searchUserById
    (
       p_userId IN User.user_id%TYPE,
       ps_name OUT User.name%TYPE,
       ps_lastName OUT User.lastName%TYPE,
       ps_email OUT User.email%TYPE,
       ps_state OUT User.state%TYPE
    )
IS
BEGIN
  SELECT name, lastName, email, state
  INTO ps_name , ps_lastName , ps_email , ps_state 
  FROM  USER WHERE user_id= p_userid;
END;
/

这是我删除的PL/SQL

CREATE OR REPLACE PROCEDURE deleteUserById
    (
       p_userId IN USER.user_ID%TYPE
    )
IS
BEGIN
  DELETE FROM USER
  WHERE user_id=p_userId;
COMMIT;
END;
/

编辑 2

我

创建了这个建议的方法，但它给了我一个错误，我缺少返回值，所以我添加了返回 null

 @Override
public void deleteUserById(final int idUser) {
    final String storedProcedureBorrarUSuario =  "{ call borrarUsuarioPorId(?) }";
    final Connection connection = null;
    jdbcTemplate.execute( new ConnectionCallback<Object>() 
    {
        @Override
        public Object doInConnection(Connection con) throws SQLException, DataAccessException 
        {
            CallableStatement callableStatement = connection.prepareCall(storedProcedureBorrarUSuario);
            callableStatement.setInt(1, idUser);
            callableStatement.executeUpdate();
            return null;
        }
    });   
}

当我运行我的单元测试时，它在此行中显示空指针异常

userDAO.deleteUserById（3）;

编辑 3

我首先尝试将用户设置为 null，因此如果有异常，我的方法将返回一个 null 对象，但当我尝试使用异常方法时，我在单元测试中仍然遇到同样的问题

@Override
public Usuario searchUserById(int userId) 
{
    User user=  null;
    Connection connection = null;
    try {
        String storedProcedureInfoUsuario  =  "{ call searchUserById(?, ?, ?, ?, ?) }";
        connection  =  jdbcTemplate.getDataSource().getConnection();
        CallableStatement callableStatement = connection.prepareCall(storedProcedureInfoUsuario);
        callableStatement.setInt(1, userId);
        callableStatement.registerOutParameter(2, Types.VARCHAR);
        callableStatement.registerOutParameter(3, Types.VARCHAR);
        callableStatement.registerOutParameter(4, Types.VARCHAR);
        callableStatement.registerOutParameter(5, Types.VARCHAR);
        callableStatement.executeQuery();
        //
        user=  new User();
        usuario.setName(callableStatement.getString(2));
        usuario.setLastName(callableStatement.getString(3));
        usuario.setEmail(callableStatement.getString(4));
        usuario.setState(callableStatement.getString(5));
    } 
    catch (SQLException ex) 
    {
//          Logger.getLogger(UsuarioDAOImplementacion.class.getName()).log(Level.SEVERE, null, ex);
            ex.printStackTrace();
        }
        finally 
        {
            if(connection != null)
            try 
            {
                connection.close();
            } 
            catch (SQLException e) 
            {
                e.printStackTrace();
            }
        }
        return user;
    }

这是我的单元测试，我希望有一个空值，这与我所做的修改有关

public void findUserById()
{
    User emptyUser=  userDAO.searchUserById(50);
    assertNull(emptyUser);
}

但是，如果我尝试使用异常方法，则会出现以下错误

@Test(expected=SQLException.class) 
public void findUserById()
    {
        User emptyUser=  userDAO.searchUserById(50);
        assertNull(emptyUser);
    }

这给了我Expected exception: java.sql.SQLException java.lang.AssertionError

我不知道如果我的输出中有以下异常，为什么这不起作用 java.sql.SQLException: ORA-01403: no data found

问题出在你的方法 serachUserById（）。我在下面的代码中为您修复了它。您始终返回用户对象。无论数据库中是否有用户。下面的代码首先将 null 分配给用户。我想如果没有具有此用户 ID 的用户，则会出现异常。因此，您捕获异常并继续返回 null。如果数据库中有用户，您将创建一个 User 对象，用值填充它并返回该对象。

关键点是要区分1.有一个用户，我用一个用户对象返回它，并且2.没有用户，我返回空值。

@Override
public User serachUserById(int userId) 
{
    User user = null;
    Connection connection = null;
    try {
        String storedProcedureInfoUsuario  =  "{ call searchUserById(?, ?, ?, ?, ?) }";
        connection  =  jdbcTemplate.getDataSource().getConnection();
        CallableStatement callableStatement = connection.prepareCall(storedProcedureInfoUsuario);
        callableStatement.setInt(1, userId);
        callableStatement.registerOutParameter(2, Types.VARCHAR);
        callableStatement.registerOutParameter(3, Types.VARCHAR);
        callableStatement.registerOutParameter(4, Types.VARCHAR);
        callableStatement.registerOutParameter(5, Types.VARCHAR);
        callableStatement.executeQuery();
        //
        user = new User();
        user.setName(callableStatement.getString(2));
        user.setLastName(callableStatement.getString(3));
        user.setEmail(callableStatement.getString(4));
        user.setState(callableStatement.getString(5));
    } 
    catch (SQLException ex) 
    {
Logger.getLogger(UsuarioDAOImplementacion.class.getName()).log(Level.SEVERE, null, ex);
        ex.printStackTrace();
    }
    finally 
    {
        if(connection != null)
        try 
        {
            connection.close();
        } 
        catch (SQLException e) 
        {
            e.printStackTrace();
        }
    }
    return user;
}

无论如何，我建议您使用Spring jpa存储库，而不是jdbc连接，SQL和存储过程。您将节省大量时间和错误。

可能有以下可能性

您的 PL/SQL 中存在问题。看看你什么时候得到这个异常？删除用户或搜索用户时。
在测试上下文的事务配置中为 defaultRollback 设置的配置值是什么？如果这是真的，这意味着您的更改在执行测试方法后会回滚，这就是为什么您可能会在搜索用户中获得价值的原因
如果其他一切正常，则可能存在事务边界问题。

对于初学者，我建议您重写JDBC代码并实际使用JdbcTemplate。无需自己管理连接，而是将逻辑包装在ConnectionCallback这样可以避免打开/关闭连接。

其次是您应该使用 executeUpdate ins 的修改

@Override
public void deleteUserById(final int idUser) {
    final String storedProcedure =  "{ call deleteUserById(?) }";
    getJdbcTemplate().execute(new ConnectionCallback<Object>() {
        public Object doInConnection(Connection con) throws SQLException, DataAccessException {
            CallableStatement callableStatement = con.prepareCall(storedProcedureBorrarUSuario);
            callableStatement.setInt(1, idUser);
            callableStatement.executeUpdate();
            return null;
        }
    });   
}
@Override
public Usuario buscarUsuarioPorId(final int userId) {       
    User user=  new  User();
    final String storedProcedureInfoUsuario  =  "{ call searchUserById(?, ?, ?, ?, ?) }";
    return getJdbcTemplate().execute(new ConnectionCallback<User>() {
        public User doInConnection(Connection con) throws SQLException, DataAccessException {
        CallableStatement callableStatement = con.prepareCall(storedProcedureInfoUsuario);
        callableStatement.setInt(1, idUsuario);
        callableStatement.registerOutParameter(2, Types.VARCHAR);
        callableStatement.registerOutParameter(3, Types.VARCHAR);
        callableStatement.registerOutParameter(4, Types.VARCHAR);
        callableStatement.registerOutParameter(5, Types.VARCHAR);
        callableStatement.executeQuery();
        //
        user.setName(callableStatement.getString(2));
        user.setLastName(callableStatement.getString(3));
        user.setEmail(callableStatement.getString(4));
        user.setState(callableStatement.getString(5));
    });
}

相关内容

最新更新

热门标签：