Category Archives: 資料庫

[MySQL] Find in fixed string

Ref. MySQL 的 FIND_IN_SET函數 SELECT * FROM table WHERE FIND_IN_SET(ID, ‘2,5,6,7,8,9,11,21,33,45’)

Posted in MySQL | Leave a comment

[HBase] Scan with filter by partial rowkey using HBase shell

If we have these rowkey list data. xx_abc xx_abc_def xx_abd xx_abd_rfg To get rowkey which contain “abc” scan ‘TableName’, FILTER => “RowFilter(=, ‘substring:abc’)” We will get these. xx_abc xx_abc_def But if we want only get “xx_abc” scan ‘TableName’, FILTER => … Continue reading

Posted in HBase | Leave a comment

[HBase] get/scan String or Integer value

get String Value get ‘Table_Name’, ‘RowKey’, {COLUMNS=>’Column_Family:Qualify:toString’} get Integer Value get ‘Table_Name’, ‘RowKey’, {COLUMNS=>’Column_Family:Qualify:toInt’} scan and get String Value scan ‘Table_Name’, {COLUMNS=>’Column_Family:Qualify:toString’} scan and get Integer Value scan ‘Table_Name’, {COLUMNS=>’Column_Family:Qualify:toInt’}

Posted in HBase | Leave a comment

[HBase] run hbase command by ruby

echo ‘list.each {|t| truncate t}; quit;’ | hbase shell or Drop Table echo ‘list.each {|t| disable t; drop t}; quit;’ | hbase shell Scan Table list.each {|t| print t; scan t, {LIMIT=>1};}

Posted in HBase, Ruby | Leave a comment

[MySQL] Resolve duplicate entry error in MySQL Replication

while [ 1 ]; do if [ $(mysql -uroot -ppassword -e”show slave status G;” | grep “Duplicate entry” | wc -l) -eq 1 ] ; then mysql -uroot -ppassword -e”stop slave; set global sql_slave_skip_counter=1; start slave;”; fi; sleep 1; mysql … Continue reading

Posted in MySQL | Leave a comment

[Java, HBase] Hostname is very important!

If the connection is failed, try to check the hdfs uri setting, it might be used hostname.

Posted in HBase, Java | Leave a comment

[HBase] Use SingleColumnFilter in shell.

scan ‘TABLENAME’, {FILTER=>”(SingleColumnValueFilter(‘CF’, ‘CQ’, =, ‘binary:VALUE’, true, true))”} the first true means filterIfColumnMissing the second true means setLatestVersionOnly Ref. Spinning Thoughts: Applying Filters in HBase shell

Posted in HBase | 2 Comments

[Java、HBase] Retrieving timestamp form HBase row

Ref. stackoverflow: retrieving timestamp from hbase row HTableInterface hTableInterface = CONNECTION.getTable(Table.SCHEMA_NAME); Result result = hTableInterface.get(get); Date date = new Date(result.raw()[0].getTimestamp()); System.out.println(“DateTime: ” + sdf.format(date)); we must edit HBaseSettings to set hbaseConf.set(HBASE_ENV_KEY_ZOOKEEPER_QUORUM, “target_zookeeper_address”);

Posted in HBase, Java | Tagged , | Leave a comment

HBase get

get ‘TableName’, ‘RowKey’ get ‘TableName’, ‘RowKey’, ‘cf:qualifier’ get ‘TableName’, ‘RowKey’, {FILTER => “ValueFilter(=, ‘binary:Search Key’)”}

Posted in HBase | Leave a comment

HBase scan

scan ‘TableName’, FILTER => “ValueFilter(=, ‘binary:Search key’)” scan ‘TableName’, {FILTER => “ValueFilter(=, ‘binary:Search key1’) OR ValueFilter(=, ‘binary:Search key2’)”} scan ‘TableName’, {COLUMNS => ‘cf:qualifer’, FILTER => “ValueFilter(>=, ‘binary:Search key1’) AND ValueFilter(<, ‘binary:Search key1~’)”} scan ‘TableName’, FILTER => “ValueFilter(=, ‘binaryprefix:+8869’)” //符合+8869開頭的 scan … Continue reading

Posted in HBase | Leave a comment