2016-02-28 83 views
1

我创建了一个java应用程序来读取HBase中的数据。我检查了link1link2link3link4。即使我的表中有数据,程序也会返回null。HBase读取数据返回null

HBase的外壳:

hbase(main):009:0> get 'login','1' 
COLUMN    CELL              
password: password timestamp=1456588594424, value=hpassword      
username: username timestamp=1456588582413, value=husername      
2 row(s) in 0.0120 seconds 

代码:

Configuration config = HBaseConfiguration.create(); 
HTable table = new HTable(config, "login"); 
Get g = new Get(Bytes.toBytes("row1")); 
Result r = table.get(g); 

byte [] value = r.getValue(Bytes.toBytes("username"),Bytes.toBytes("username")); 
byte [] value1 = r.getValue(Bytes.toBytes("password"),Bytes.toBytes("password")); 

String valueStr = Bytes.toString(value); 
String valueStr1 = Bytes.toString(value1); 
System.out.println("username: "+ valueStr+"\npassword: "+valueStr1); 
Scan s = new Scan(); 
s.addColumn(Bytes.toBytes("username"), Bytes.toBytes("username")); 
s.addColumn(Bytes.toBytes("password"), Bytes.toBytes("password")); 
ResultScanner scanner = table.getScanner(s); 

try 
{ 
for (Result rnext = scanner.next(); rnext != null; rnext = scanner.next()) 
    { 
    System.out.println("Found row : " + rnext); 
    } 
}finally{ 
    scanner.close(); 
} 

输出:

username: null 
password: null 

我失去了一些东西,或者我需要在代码编辑的地方?

此外,我需要将其实现到Java Play Framework中。你有什么想法吗?

在此先感谢。

+0

目前还不清楚哪些列族用于存储数据。你使用“用户名”列和列家庭,它似乎是错误的 – AdamSkywalker

+0

谢谢你的帮助。我改变了它们,并将Bytes.toBytes(“row1”))“row1”更改为“1”。 –

+0

为什么你使用扫描并在同一时间? –

回答

2

为@AdamSkywalker说,我需要改变的列名和列族的名字。当他们的名字相同时,我得到空回报。 我将它们重命名并且代码完美无缺。

2

试试这个:

// Instantiating Configuration class 
    Configuration config = HBaseConfiguration.create(); 

    // Instantiating HTable class 
    HTable table = new HTable(config, "tablename"); 

    // Instantiating the Scan class 
    Scan scan = new Scan(); 

    // Scanning the required columns 
    scan.addColumn(Bytes.toBytes("columnfamily"), Bytes.toBytes("column1")); 
    scan.addColumn(Bytes.toBytes("columnfamily"), Bytes.toBytes("column2")); 

    // Getting the scan result 
    ResultScanner scanner = table.getScanner(scan); 

    // Reading values from scan result 
    for (Result result = scanner.next(); result != null; result = scanner.next()) 

    System.out.println("Found row : " + result); 
    //closing the scanner 
    scanner.close(); 
+0

列名和列族具有相同的名称,我更改了它们的名称。它现在正在完美工作。 感谢您提供更干净的代码。 –