mysql数据加载到redis(hset)

点击(此处)折叠或打开

package com.hxl;

import redis.clients.jedis.Jedis;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Date;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;

public class LoadDataToHset {
    public static void main(String[] args) {
        // 连接本地的 Redis 服务
        Jedis jedis = new Jedis("192.168.56.101");
        System.out.println(new Date());

        Map map = new HashMap();
        map = getData();
        Iterator iter = map.entrySet().iterator();
        while (iter.hasNext()) {
            Map.Entry entry = (Map.Entry) iter.next();
            String mkey =(String) entry.getKey();
            String val =(String) entry.getValue();
            //System.out.println(key+"--"+val);
            jedis.hset("hset_test", mkey, val);
        }

        System.out.println(new Date());

    }

    @SuppressWarnings("static-access")
    public static HashMap<String, String> getData() {

        HashMap<String, String> map = new HashMap<String, String>();

        PreparedStatement ps = null;
        ResultSet rs = null;
        Connection conn = null;

        try {
            conn = new DbManager().getConnection();
            ps = (PreparedStatement) conn.prepareStatement(
                    "SELECT usernumber,act_cnt FROM hxl.tb_user",
                    ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);

            ps.setFetchSize(Integer.MIN_VALUE);
            ps.setFetchDirection(ResultSet.FETCH_REVERSE);
            rs = ps.executeQuery();
            // 处理结果集
            while (rs.next()) {
                map.put(rs.getString("usernumber"), rs.getString("act_cnt"));
            }

            rs.close(); // 关闭数据库
            conn.close();

        } catch (InstantiationException e) {
            e.printStackTrace();
        } catch (IllegalAccessException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return map;
    }
}

数据库连接：

package com.hxl;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class DbManager {

    final static String url = "jdbc:mysql://192.168.56.102/hxl";
    final static String user = "root";
    final static String pwd = "mysql";

    public static Connection getConnection() throws InstantiationException,
            IllegalAccessException, ClassNotFoundException, SQLException {
        Connection conn = null;
        Class.forName("com.mysql.jdbc.Driver").newInstance();
        // 建立到MySQL的连接
        conn = DriverManager.getConnection(url, user, pwd);
        return conn;
    }

    public static void main(String[] args) throws InstantiationException,
            IllegalAccessException, ClassNotFoundException, SQLException {

        DbManager dbm = new DbManager();

        if (DbManager.getConnection() != null) {
            System.out.println("Connect Success!");
        }

    }

}