Class SqlTableParam

zap/src/main/java/org/zaproxy/zap/db/sql/SqlTableParam.java:32–168

import org.parosproxy.paros.db.TableParam;

public class SqlTableParam extends SqlAbstractTable implements TableParam {

    private static final String TABLE_NAME = DbSQL.getSQL("param.table_name");

    private static final String PARAMID = DbSQL.getSQL("param.field.paramid");
    private static final String SITE = DbSQL.getSQL("param.field.site");
    private static final String TYPE = DbSQL.getSQL("param.field.type");
    private static final String NAME = DbSQL.getSQL("param.field.name");
    private static final String USED = DbSQL.getSQL("param.field.used");
    private static final String FLAGS = DbSQL.getSQL("param.field.flags");
    private static final String VALUES = DbSQL.getSQL("param.field.vals");

    public SqlTableParam() {}

    @Override
    protected void reconnect(Connection conn) throws DatabaseException {
        try {
            if (!DbUtils.hasTable(conn, TABLE_NAME)) {
                // Need to create the table
                DbUtils.execute(conn, DbSQL.getSQL("param.ps.addtable"));
            }
        } catch (SQLException e) {
            throw new DatabaseException(e);
        }
    }

    @Override
    public synchronized RecordParam read(long urlId) throws DatabaseException {
        SqlPreparedStatementWrapper psRead = null;
        try {
            psRead = DbSQL.getSingleton().getPreparedStatement("param.ps.read");
            psRead.getPs().setLong(1, urlId);

            try (ResultSet rs = psRead.getPs().executeQuery()) {
                return build(rs);
            }
        } catch (SQLException e) {
            throw new DatabaseException(e);
        } finally {
            DbSQL.getSingleton().releasePreparedStatement(psRead);
        }
    }

    @Override
    public List<RecordParam> getAll() throws DatabaseException {
        SqlPreparedStatementWrapper psGetAll = null;
        try {
            psGetAll = DbSQL.getSingleton().getPreparedStatement("param.ps.getall");
            List<RecordParam> result = new ArrayList<>();
            try (ResultSet rs = psGetAll.getPs().executeQuery()) {
                while (rs.next()) {
                    result.add(
                            new RecordParam(
                                    rs.getLong(PARAMID),
                                    rs.getString(SITE),
                                    rs.getString(TYPE),
                                    rs.getString(NAME),
                                    rs.getInt(USED),