CRVM-redis-6/HBase/Program.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.IO;
using Newtonsoft.Json;
using System.Net;
using System.Threading;

namespace Baosight.HBase
{
    class TOKEN
    {
        public string token { get; set; }
        public string errcode { get; set; }
    }

    class Program
    {
        static void Main(string[] args)
        {

            HbaseUnit hbase = new HbaseUnit("admin@crvm", "admin", "http://10.25.27.53/otsrest/api/");

            //##Create file record
            //byte[] data_file_in = hbase.File2Bytes("D:\\mp3\\Taylor Swift - Out Of The Woods.mp3");

            //for (int i = 0; i < 10; i++)
            //{
                
            //    string retString = hbase.PostBytes("record/file/T_CYC_SHAKE?key="+i.ToString()+".mp3&column=mp3", data_file_in);//huangming_mob是表名
            //    Console.WriteLine("up load file>{0}:{1}\n",i, retString);
            //}

            //for (int i = 0; i < 10; i++)
            //{
            //    //##Get file record
            //    byte[] data_file_out = hbase.GetBytes("record/file/T_CYC_SHAKE?key=" + i.ToString() + ".mp3&column=mp3");//huangming_mob是表名

            //    hbase.Bytes2File(data_file_out, "D:\\mp3\\" + i.ToString() + ".mp3");
            //    Console.WriteLine("down load file>{0}:{1}\n", i, i.ToString() + ".mp3");
            //}
            Console.WriteLine("start ");
            for (int i = 0; i < 10; i++)
            {
               
                Thread t = new Thread(new ThreadStart(delegate()
                {
                    //HbaseUnit hbase = new HbaseUnit("admin@crvm", "admin", "http://10.25.27.53/otsrest/api/");
                    //##Get file record
                    byte[] data_file_out = hbase.GetBytes("record/file/T_CYC_SHAKE?key=" + i.ToString() + ".mp3&column=mp3");//huangming_mob是表名

                    hbase.Bytes2File(data_file_out, "D:\\mp3\\" + i.ToString() + ".mp3");
                    Console.WriteLine("down load file>{0}:{1}\n", i, i.ToString() + ".mp3");

                }));
                t.Start();
            }
            Console.WriteLine("end ");

            

           
            ////##Create table
            ////String create_table = "{\"compression\":\"snappy\",\"max_versions\":1,\"description\":\"\",\"mob_enabled\":false,\"mob_threshold\":0}";            
            //StringWriter sw = new StringWriter();
            //JsonWriter writer = new JsonTextWriter(sw);
            //writer.WriteStartObject();
            //writer.WritePropertyName("description");
            //writer.WriteValue("");
            //writer.WritePropertyName("compression");
            //writer.WriteValue("snappy");
            //writer.WritePropertyName("max_versions");
            //writer.WriteValue(1);
            //writer.WritePropertyName("mob_enabled");
            //writer.WriteValue(false);
            //writer.WritePropertyName("mob_threshold");
            //writer.WriteValue(0);
            //writer.WriteEndObject();
            //writer.Flush();
            //String create_table = sw.GetStringBuilder().ToString();

            //string retString = hbase.Post("table/huangming", create_table);//huangming是表名
            //Console.WriteLine("\nC#======>{0}\n", retString);
            //retString = hbase.Get("table/huangming");
            //Console.WriteLine("\nC#======>{0}\n", retString);

            ////##Create normal record
            ////String create_record = "{\"records\":[ {\"id\":\"10000\", \"huang\":\"abc0\"} ] }";
            //StringWriter sw_rec = new StringWriter();
            //JsonWriter writer_rec = new JsonTextWriter(sw_rec);
            //writer_rec.WriteStartObject();
            //writer_rec.WritePropertyName("records");
            //writer_rec.WriteStartArray();

            //writer_rec.WriteStartObject();
            //writer_rec.WritePropertyName("id");
            //writer_rec.WriteValue("10000");
            //writer_rec.WritePropertyName("huang");
            //writer_rec.WriteValue("abc0");
            //writer_rec.WriteEndObject();

            //writer_rec.WriteEndArray();
            //writer_rec.WriteEndObject();
            //writer_rec.Flush();
            //String create_record = sw_rec.GetStringBuilder().ToString();
            //retString = hbase.Post("record/huangming", create_record);//huangming是表名
            //Console.WriteLine("\nC#======>{0}\n", retString);

            ////##Get normal record
            //retString = hbase.Get("record/huangming?key=10000");
            //Console.WriteLine("\nC#======>{0}\n", retString);

            //retString = hbase.Get("record/huangming?keyexp=*");
            //Console.WriteLine("\nC#======>{0}\n", retString);

            ////##Update normal record
            ////String update_record = "{\"records\":[ {\"id\":\"10000\", \"huang\":\"abc0_update\"} ] }";
            //StringWriter sw_rec2 = new StringWriter();
            //JsonWriter writer_rec2 = new JsonTextWriter(sw_rec2);
            //writer_rec2.WriteStartObject();
            //writer_rec2.WritePropertyName("records");
            //writer_rec2.WriteStartArray();

            //writer_rec2.WriteStartObject();
            //writer_rec2.WritePropertyName("id");
            //writer_rec2.WriteValue("10000");
            //writer_rec2.WritePropertyName("huang");
            //writer_rec2.WriteValue("abc0_update");
            //writer_rec2.WriteEndObject();

            //writer_rec2.WriteEndArray();
            //writer_rec2.WriteEndObject();
            //writer_rec2.Flush();
            //String update_record = sw_rec2.GetStringBuilder().ToString();
            //retString = hbase.Post("record/huangming", update_record);//huangming是表名
            //Console.WriteLine("\nC#======>{0}\n", retString);
            //retString = hbase.Get( "record/huangming?key=10000");
            //Console.WriteLine("\nC#======>{0}\n", retString);

            ////##Delete normal record
            //retString = hbase.Delete("record/huangming?key=10000");
            //Console.WriteLine("\nC#======>{0}\n", retString);
            //retString = hbase.Get("record/huangming?key=10000");
            //Console.WriteLine("\nC#======>{0}\n", retString);

            ////##Update table
            ////String update_table = "{\"description\": \"hello\"}";
            //StringWriter sw2 = new StringWriter();
            //JsonWriter writer2 = new JsonTextWriter(sw2);
            //writer2.WriteStartObject();
            //writer2.WritePropertyName("description");
            //writer2.WriteValue("hello");
            //writer2.WriteEndObject();
            //writer2.Flush();
            //String update_table = sw2.GetStringBuilder().ToString();
            //retString = hbase.Put("table/huangming", update_table);//huangming是表名
            //Console.WriteLine("\nC#======>{0}\n", retString);
            //retString = hbase.Get("table/huangming");
            //Console.WriteLine("\nC#======>{0}\n", retString);

            ////##Delete table
            //retString = hbase.Delete("table/huangming");//huangming是表名
            //Console.WriteLine("\nC#======>{0}\n", retString);
            //retString = hbase.Get("table/huangming");
            //Console.WriteLine("\nC#======>{0}\n", retString);

            ////##Create table with mob
            ////String create_table_mob = "{\"compression\":\"snappy\",\"max_versions\":1,\"description\":\"\",\"mob_enabled\":true,\"mob_threshold\":100}";            
            //StringWriter sw_mob = new StringWriter();
            //JsonWriter writer_mob = new JsonTextWriter(sw_mob);
            //writer_mob.WriteStartObject();
            //writer_mob.WritePropertyName("description");
            //writer_mob.WriteValue("");
            //writer_mob.WritePropertyName("compression");
            //writer_mob.WriteValue("snappy");
            //writer_mob.WritePropertyName("max_versions");
            //writer_mob.WriteValue(1);
            //writer_mob.WritePropertyName("mob_enabled");
            //writer_mob.WriteValue(true);
            //writer_mob.WritePropertyName("mob_threshold");
            //writer_mob.WriteValue(100);
            //writer_mob.WriteEndObject();
            //writer_mob.Flush();
            //String create_table_mob = sw_mob.GetStringBuilder().ToString();
            //retString = hbase.Post("table/huangming_mob", create_table_mob);//huangming_mob是表名
            //Console.WriteLine("\nC#======>{0}\n", retString);
            //retString = hbase.Get("table/huangming_mob");
            //Console.WriteLine("\nC#======>{0}\n", retString);

            ////##Create file record
            //byte[] data_file_in = hbase.File2Bytes("D:\\mp3\\Taylor Swift - Out Of The Woods.mp3");
            //retString = hbase.PostBytes("record/file/huangming_mob?key=away.mp3&column=mp3", data_file_in);//huangming_mob是表名
            //Console.WriteLine("\nC#======>{0}\n", retString);

            ////##Get file record
            //byte[] data_file_out = hbase.GetBytes("record/file/huangming_mob?key=away.mp3&column=mp3");//huangming_mob是表名
            //hbase.Bytes2File(data_file_out, "D:\\mp3\\Out Of The Woods.mp3");

            //##Delete table with mob
            //retString = hbase.Delete("table/huangming_mob");//huangming_mob是表名
            //Console.WriteLine("\nC#======>{0}\n", retString);
            //retString = hbase.Get("table/huangming_mob");
            //Console.WriteLine("\nC#======>{0}\n", retString);

            Console.ReadLine();
        }

        
    }
}