@Override
    public MapConnector<String, Double> forceSynchronization() throws Exception {
        try (Connection con = getConnectorInfo().getConnection()) {
            forceClear();
            int n = 0;
            StringBuilder values = new StringBuilder();
            String stm;
            for (String s : getMap().keySet()) {
                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++;
                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;
                }
            }
        }
        return this;
    }