phoenix的数据查询列表方法

拼搏现实的明天。 2022-10-31 12:18 73阅读 0赞

直接上码：

@Autowired  
    private PhoenixProperties phoenixConfig;

private List<Map<String,Object>> queryForList(String sql)  
    \{  
        List<Map<String,Object>> resultList = new ArrayList<>();  
          
        Connection con = null;  
        PreparedStatement statement = null;  
          
        try \{  
            Class.forName(phoenixConfig.getDriver());  
        \} catch (ClassNotFoundException e1) \{  
            // TODO Auto-generated catch block  
            e1.printStackTrace();  
        \}  
        try \{  
            Properties props = new Properties();  
            props.setProperty("phoenix.query.timeoutMs", "1200000");  
            props.setProperty("hbase.rpc.timeout", "1200000");  
            props.setProperty("hbase.client.scanner.timeout.period", "1200000");  
              
            con = DriverManager.getConnection(phoenixConfig.getUrl(),props);  
            statement = con.prepareStatement(sql);  
            ResultSet rset = statement.executeQuery();  
            //获取ResultSet集合信息对象  
            ResultSetMetaData rsmd = rset.getMetaData();  
            Map<String, Object> tempHash = null;  
            while (rset.next()) \{  
                tempHash = new HashMap<String, Object>();  
                for (int i = 0; i < rsmd.getColumnCount(); i++) \{  
                    // 遍历每列数据，以键值形式存在对象tempHash中  
                    tempHash.put(rsmd.getColumnName(i + 1).toUpperCase(),rset.getObject(rsmd.getColumnName(i + 1)));  
                \}  
                resultList.add(tempHash);  
            \}  
            rset.close();  
            statement.close();  
            con.close();  
        \} catch (SQLException e) \{  
            // TODO Auto-generated catch block  
            e.printStackTrace();  
        \}  
          
        return resultList;  
          
    \}

其中的配置类：

@Component  
@ConfigurationProperties(prefix = "sys.phoenix", ignoreUnknownFields = true)  
public class PhoenixProperties \{  
    private String driver;  
    private String url;  
    private String user;  
    private String password;  
    private String type;  
    private String autocommit;  
      
    public String getUrl() \{  
        return url;  
    \}  
    public void setUrl(String url) \{  
        this.url = url;  
    \}  
    public String getUser() \{  
        return user;  
    \}  
    public void setUser(String user) \{  
        this.user = user;  
    \}  
    public String getPassword() \{  
        return password;  
    \}  
    public void setPassword(String password) \{  
        this.password = password;  
    \}  
    public String getDriver() \{  
        return driver;  
    \}  
    public void setDriver(String driver) \{  
        this.driver = driver;  
    \}  
    public String getType() \{  
        return type;  
    \}  
    public void setType(String type) \{  
        this.type = type;  
    \}  
    public String getAutocommit() \{  
        return autocommit;  
    \}  
    public void setAutocommit(String autocommit) \{  
        this.autocommit = autocommit;  
    \}  
      
\}