@Override
    public MapConnector<String, Integer> forceSynchronization() throws SQLException {
        super.addSQLJob(new SQLJob<String, Integer>() {
            @Override
            public void executeJob(Connection con, Map<String, Integer> map) throws SQLException {
                StrIntNonBlockingConnector.this.forceClear();
                int n = 0;
                StringBuilder values = new StringBuilder();
                String stm;
                for (String s : getMap().keySet()) {
                    if (n == BLOCK_INSERT_COUNT || n == getMap().size() - 1) {
                        stm = "INSERT INTO " + getConnectorInfo().getTableName() + "(key,value) VALUES " + values.toString() + ";";
                        try (PreparedStatement prepStm = con.prepareStatement(stm)) {
                            prepStm.execute();
                        }
                        values = new StringBuilder();
                        n = 0;
                    }
                    values = values.append("(").append("'").append(s).append("'").append(",").append(getMap().get(s)).append(")");
                    if (n + 1 != BLOCK_INSERT_COUNT && n + 1 != getMap().size() - 1) {
                        values = values.append(",");
                    }
                    n++;
                }
            }
        });
        return this;
    }