nacos只支持mysql的原因分析

2024年2月5日发(作者：)

protected void init() { jt = cTemplate(); }

/** * Execute create user operation. * * @param username username string value. * @param password password string value. */ public void createUser(String username, String password) { String sql = "INSERT into users (username, password, enabled) VALUES (?, ?, ?)";

try { (sql, username, password, true); } catch (CannotGetJdbcConnectionException e) { _("[db-error] " + ng(), e); throw e; } }

/** * Execute delete user operation. * * @param username username string value. */ public void deleteUser(String username) { String sql = "DELETE from users WHERE username=?"; try { (sql, username); } catch (CannotGetJdbcConnectionException e) { _("[db-error] " + ng(), e); throw e; } }

/** * Execute update user password operation. * * @param username username string value. * @param password password string value. */ public void updateUserPassword(String username, String password) { try { ("UPDATE users SET password = ? WHERE username=?", password, username); } catch (CannotGetJdbcConnectionException e) { _("[db-error] " + ng(), e); throw e; } }

/** * Execute find user by username operation. * * @param username username string value. * @return User model. */ public User findUserByUsername(String username) { String sql = "SELECT username,password FROM users WHERE username=? "; try { return orObject(sql, new Object[] {username}, USER_ROW_MAPPER); } catch (CannotGetJdbcConnectionException e) { _("[db-error] " + ng(), e); throw e; } catch (EmptyResultDataAccessException e) { return null; } catch (Exception e) { _("[db-other-error]" + sage(), e); throw new RuntimeException(e); } }

public Page getUsers(int pageNo, int pageSize) {

PaginationHelper helper = PaginationHelper();