import java.io.IOException;
import java.nio.CharBuffer;
import java.nio.charset.Charset;
import java.sql.*;
import java.util.*;

public class WordPressDataBaseFixer {
    private static Connection connect;
    private static Statement statement;
    private static ResultSet resultSet;
    private static PreparedStatement preparedStatement;


    public static void main(String[] args) throws ClassNotFoundException, SQLException, IOException {
        Class.forName("com.mysql.jdbc.Driver");
        // Setup the connection with the DB
        connect = DriverManager
                .getConnection("jdbc:mysql://localhost/wordpress?"
                        + "user=root&password=develop");
        statement = connect.createStatement(ResultSet.TYPE_FORWARD_ONLY,ResultSet.CONCUR_UPDATABLE);
        // Result set get the result of the SQL query
/*
        resultSet = statement.executeQuery("show tables");
//        writeResultSet(resultSet);

        Map<String, List<String>> tables = new HashMap<String, List<String>>();
        while (resultSet.next()) {
            tables.put(resultSet.getString(1), new LinkedList<String>());
        }

//        System.out.println("tables = " + tables);

        for (String table : tables.keySet()) {
            resultSet = statement.executeQuery("show columns from " + table);
            while (resultSet.next()) {
                tables.get(table).add(resultSet.getString(1));
            }
//            System.out.println("table = " + table);
//            System.out.println("tables.get(table) = " + tables.get(table));
        }
*/

        updateTable("wp_options", Arrays.asList(3,4));
        updateTable("wp_posts", Arrays.asList(5, 6, 7, 12, 17));

        connect.close();
    }

    private static boolean updateTable(String tableName, List<Integer> columns) throws SQLException {
        Charset utf8charset = Charset.forName("UTF-8");
        Charset windows1258charset = Charset.forName("windows-1258");


        String query = String.format("select * from " + tableName/*, column, table*/);
        resultSet = statement.executeQuery(query);
        while (resultSet.next()) {
            try {
                for (int i : columns) {
                    String s = resultSet.getString(i);
                    CharBuffer buffer = utf8charset.decode(windows1258charset.encode(s));
                    System.out.println(String.format("%s = %s",s, buffer));
                    resultSet.updateString(i,new String(buffer.array()));
                }
                resultSet.updateRow();
            } catch (SQLException e) {
                e.printStackTrace();
                return true;
            }
        }
//            }
//        }
        return false;
    }


}