jdbcsystemdatabase.java

这是linux下ssl vpn的实现程序

            ps.releasePreparedStatement();
        }
        ps = db.getStatement("removeTunnel.deleteTunnel");
        try {
            ps.setInt(1, id);
            ps.execute();
        } finally {
            ps.releasePreparedStatement();
        }
        return t;
    }

    //
    // Favorites
    //

    /*
     * (non-Javadoc)
     * 
     * @see com.sslexplorer.security.SystemDatabase#addFavorite(int, int,
     *      java.lang.String)
     */
    public void addFavorite(int type, int favoriteKey, String username) throws Exception {
        JDBCPreparedStatement ps = db.getStatement("addFavorite.insert");
        try {
            ps.setInt(1, type);
            ps.setString(2, username == null ? "" : username);
            ps.setInt(3, favoriteKey);
            ps.execute();
            ps.reset();
        } finally {
            ps.releasePreparedStatement();
        }
    }

    /*
     * (non-Javadoc)
     * 
     * @see com.sslexplorer.security.SystemDatabase#removeFavorite(int, int,
     *      java.lang.String)
     */
    public void removeFavorite(int type, int favoriteKey, String username) throws Exception {
        JDBCPreparedStatement ps = db.getStatement("removeFavorite.delete");
        try {
            ps.setInt(1, type);
            ps.setString(2, username == null ? "" : username);
            ps.setInt(3, favoriteKey);
            ps.execute();
        } finally {
            ps.releasePreparedStatement();
        }

    }

    /*
     * (non-Javadoc)
     * 
     * @see com.sslexplorer.security.SystemDatabase#getFavorites(int,
     *      com.sslexplorer.security.User)
     */
    public List getFavorites(int type, User user) throws Exception {
        JDBCPreparedStatement ps = null;
        if (type == -1) {
            ps = db.getStatement("getFavorites.selectAllForUser");
            ps.setString(1, user == null ? "" : user.getPrincipalName());
        } else {
            ps = db.getStatement("getFavorites.selectTypeForUser");
            ps.setString(1, user == null ? "" : user.getPrincipalName());
            ps.setInt(2, type);
        }
        try {
            Vector v = new Vector();
            ResultSet rs = ps.executeQuery();
            try {
                while (rs.next()) {

                    v.add(new DefaultFavorite(rs.getInt("favorite_id"), type, user == null ? null : user.getPrincipalName(), rs.getInt("favorite_key")));
                }
            } finally {
                rs.close();
            }
            return v;
        } finally {
            ps.releasePreparedStatement();
        }

    }

    /*
     * (non-Javadoc)
     * 
     * @see com.sslexplorer.security.SystemDatabase#getFavorite(int,
     *      com.sslexplorer.security.User, java.lang.String)
     */
    public Favorite getFavorite(int type, User user, int resourceId) throws Exception {
        JDBCPreparedStatement ps = db.getStatement("getFavorite.select");
        ps.setString(1, user == null ? "" : user.getPrincipalName());
        ps.setInt(2, type);
        ps.setInt(3, resourceId);
        try {
            ResultSet rs = ps.executeQuery();
            try {
                if (rs.next()) {
                    return new DefaultFavorite(rs.getInt("favorite_id"), type, user == null ? null : user.getPrincipalName(), rs.getInt("favorite_key"));
                }
            } finally {
                rs.close();
            }
        } finally {
            ps.releasePreparedStatement();
        }
        return null;

    }

    //
    // Tunnels
    //

    /*
     * (non-Javadoc)
     * 
     * @see com.sslexplorer.security.SystemDatabase#getTunnels(java.lang.String)
     */
    public List getTunnels() throws Exception {
        JDBCPreparedStatement ps = db.getStatement("getTunnels.select");
        List v = new ArrayList();
        try {
            ResultSet rs = ps.executeQuery();
            try {
                while (rs.next()) {
                    v.add(buildTunnel(rs));
                }
            } finally {
                rs.close();
            }
        } finally {
            ps.releasePreparedStatement();
        }
        return v;
    }

    /*
     * (non-Javadoc)
     * 
     * @see com.sslexplorer.security.SystemDatabase#getTunnel(java.lang.String)
     */
    public Tunnel getTunnel(String name) throws Exception {
        JDBCPreparedStatement ps = db.getStatement("getTunnel.select.name");
        ps.setString(1, name);
        try {
            ResultSet rs = ps.executeQuery();
            try {
                if (rs.next()) {
                    return buildTunnel(rs);
                }
            } finally {
                rs.close();
            }
        } finally {
            ps.releasePreparedStatement();
        }
        return null;
    }

    /*
     * (non-Javadoc)
     * 
     * @see com.sslexplorer.security.SystemDatabase#getTunnel(int)
     */
    public Tunnel getTunnel(int id) throws Exception {
        JDBCPreparedStatement ps = db.getStatement("getTunnel.select.id");
        ps.setInt(1, id);
        try {
            ResultSet rs = ps.executeQuery();
            try {
                if (rs.next()) {
                    return buildTunnel(rs);
                }
            } finally {
                rs.close();
            }
        } finally {
            ps.releasePreparedStatement();
        }
        return null;
    }

    //
    // Web Forwards
    //

    /*
     * (non-Javadoc)
     * 
     * @see com.sslexplorer.security.SystemDatabase#getReverseProxyWebForward(com.sslexplorer.security.User,
     *      java.lang.String)
     */
    public WebForward getReverseProxyWebForward(User user, String pathInContext) throws Exception {
        JDBCPreparedStatement ps = db.getStatement("getReverseProxyWebForward.select");
        ps.setString(1, "");
        ps.setString(2, user == null ? "" : user.getPrincipalName());
        ps.setString(3, pathInContext);

        try {
            ResultSet rs = ps.executeQuery();
            try {
                if (rs.next()) {
                    return getWebForward(rs.getInt("webforward_id"));
                }
            } finally {
                if (rs != null) {
                    rs.close();
                }
            }
        } finally {
            ps.releasePreparedStatement();
        }
        return null;
    }

    //
    // Web Forwards
    //

    /*
     * (non-Javadoc)
     * 
     * @see com.sslexplorer.security.SystemDatabase#getWebForward(int)
     */
    public WebForward getWebForward(int id) throws Exception {
        JDBCPreparedStatement ps = db.getStatement("getWebForward.selectById");
        ps.setInt(1, id);
        try {
            ResultSet rs = ps.executeQuery();
            try {
                if (rs.next()) {
                    return buildWebForward(rs);
                }
            } finally {
                rs.close();
            }
        } finally {
            ps.releasePreparedStatement();
        }
        return null;
    }

    public List getWebForwards(int type) throws Exception {
        JDBCPreparedStatement ps = null;
        if (type != -1) {
            ps = db.getStatement("getWebForwards.select.type");
            ps.setInt(1, type);
            ps.setString(2, "");
        } else {
            ps = db.getStatement("getWebForwards.select.allTypes");
        }
        try {
            ResultSet rs = ps.executeQuery();
            try {
                List v = new ArrayList();
                while (rs.next()) {
                    v.add(buildWebForward(rs));
                }
                return v;
            } finally {
                if (rs != null) {
                    rs.close();
                }
            }
        } finally {
            ps.releasePreparedStatement();
        }
    }

    public List getWebForwards() throws Exception {
        JDBCPreparedStatement ps = db.getStatement("getWebForwards.select.allTypes");
        try {
            ResultSet rs = ps.executeQuery();
            try {
                List v = new ArrayList();
                while (rs.next()) {
                    v.add(buildWebForward(rs));
                }
                return v;
            } finally {
                if (rs != null) {
                    rs.close();
                }
            }
        } finally {
            ps.releasePreparedStatement();
        }
    }

    public WebForward getWebForward(String name) throws Exception {
        JDBCPreparedStatement ps = null;
        try {
            ps = db.getStatement("getWebForward.select.name");
            ps.setString(1, name);
            ResultSet rs = ps.executeQuery();
            try {
                if (rs.next()) {
                    return buildWebForward(rs);
                }
            } finally {
                rs.close();
            }
        } finally {
            ps.releasePreparedStatement();
        }
        return null;
    }

    
    public boolean reverseProxyPathExists(String path) throws Exception {
        JDBCPreparedStatement ps = null;
        try {
            ps = db.getStatement("createWebForward.reverseProxy.path.exists");
            ps.setString(1, path);
            ResultSet rs = ps.executeQuery();
            try {
                if (rs.next()) {
                    return true;
                }
                else{
                    return false;
                }
            } finally {
                rs.close();
            }
        } finally {
            ps.releasePreparedStatement();
        }
    }
    
    public boolean reverseProxyPathExists(String path, int webforward_id) throws Exception {
        JDBCPreparedStatement ps = null;
        try {
            ps = db.getStatement("createWebForward.reverseProxy.path.already.exists");
            ps.setString(1, path);
            ps.setInt(2, webforward_id);
            ResultSet rs = ps.executeQuery();
            try {
                if (rs.next()) {
                    return true;
                }
                else{
                    return false;
                }
            } finally {
                rs.close();
            }
        } finally {
            ps.releasePreparedStatement();
        }