cassandra操作封装类代码,CSharp代码库,德仔网

代码语言
代码分类
【CSharp】 cassandra操作封装类
作者:若菲 / 发布于2014/6/17/ 537

	using System;
	using System.Collections.Generic;
	using System.Linq;
	using System.Text;
	namespace CassandraDemo
	{
	 using Apache.Cassandra;
	 using Thrift;
	 using Thrift.Protocol;
	 using Thrift.Transport;
	 public class CassandraHelper
	 {
	 string m_space;
	 string m_family;
	 string m_host;
	 int m_port;
	 public CassandraHelper(string host, int port, string space, string family)
	 {
	 m_space = space;
	 m_family = family;
	 m_host = host;
	 m_port = port;
	 }
	 public void DisplayKey(string key)
	 {
	 TTransport m_socket = null;
	 TTransport m_trans = null;
	 TProtocol m_proto = null;
	 try
	 {
	 m_socket = new TSocket(m_host, m_port);
	 m_trans = new TFramedTransport(m_socket);
	 m_proto = new TBinaryProtocol(m_trans);
	 m_trans.Open();
	 Cassandra.Client cass = new Cassandra.Client(m_proto);
	 cass.set_keyspace(m_space);
	 ColumnParent cparent = new ColumnParent();
	 cparent.Column_family = m_family;
	 // get the entire row for a key
	 SliceRange sr = new SliceRange();
	 sr.Start = Encoding.UTF8.GetBytes("");
	 sr.Finish = Encoding.UTF8.GetBytes("");
	 SlicePredicate sp = new SlicePredicate();
	 sp.Slice_range = sr;
	 sp.__isset.slice_range = true; // set __isset for the columns instead if you use them

	 KeyRange range = new KeyRange();
	 range.Start_key = Encoding.UTF8.GetBytes(key);
	 range.End_key = Encoding.UTF8.GetBytes(key);
	 range.__isset.start_key = true;
	 range.__isset.end_key = true;

	 List<KeySlice> results = cass.get_range_slices(cparent, sp, range, ConsistencyLevel.ONE);
	 if (results == null || results.Count == 0)
	 {
	 Console.WriteLine("key:" + key + " dos't insert..");
	 }
	 foreach (KeySlice result in results)
	 {
	 Console.WriteLine("Key: " + Encoding.UTF8.GetString(result.Key));
	 foreach (ColumnOrSuperColumn csc in result.Columns)
	 {
	 Console.WriteLine("Column: " + Encoding.UTF8.GetString(csc.Column.Name) + " Value: " + Encoding.UTF8.GetString(csc.Column.Value));
	 }
	 }
	 }
	 catch (TTransportException te)
	 {
	 Console.WriteLine("TTransportException: " + te);
	 }
	 catch (InvalidRequestException ire)
	 {
	 Console.WriteLine("InvalidRequestException: " + ire);
	 }
	 catch (NotFoundException nfe)
	 {
	 Console.WriteLine("NotFoundException: " + nfe);
	 }
	 catch (UnavailableException ue)
	 {
	 Console.WriteLine("UnavailableException: " + ue);
	 }
	 catch (Exception ex)
	 {
	 Console.WriteLine(ex);
	 }
	 finally
	 {
	 if (m_trans != null)
	 {
	 m_trans.Close();
	 }
	 }
	 }
	 public bool IsKeyExist(string key)
	 {
	 TTransport m_socket = null;
	 TTransport m_trans = null;
	 TProtocol m_proto = null;
	 try
	 {
	 m_socket = new TSocket(m_host, m_port);
	 m_trans = new TFramedTransport(m_socket);
	 m_proto = new TBinaryProtocol(m_trans);
	 m_trans.Open();
	 Cassandra.Client cass = new Cassandra.Client(m_proto);
	 cass.set_keyspace(m_space);
	 ColumnParent cparent = new ColumnParent();
	 cparent.Column_family = m_family;
	 // get the entire row for a key
	 SliceRange sr = new SliceRange();
	 sr.Start = Encoding.UTF8.GetBytes("");
	 sr.Finish = Encoding.UTF8.GetBytes("");
	 SlicePredicate sp = new SlicePredicate();
	 sp.Slice_range = sr;
	 sp.__isset.slice_range = true; // set __isset for the columns instead if you use them
	 int count = cass.get_count(Encoding.UTF8.GetBytes(key), cparent, sp, ConsistencyLevel.ONE);
	 return count > 0;
	 }
	 catch (TTransportException te)
	 {
	 Console.WriteLine("TTransportException: " + te);
	 }
	 catch (InvalidRequestException ire)
	 {
	 Console.WriteLine("InvalidRequestException: " + ire);
	 }
	 catch (NotFoundException nfe)
	 {
	 Console.WriteLine("NotFoundException: " + nfe);
	 }
	 catch (UnavailableException ue)
	 {
	 Console.WriteLine("UnavailableException: " + ue);
	 }
	 catch (Exception ex)
	 {
	 Console.WriteLine(ex);
	 }
	 finally
	 {
	 if (m_trans != null)
	 {
	 m_trans.Close();
	 }
	 }
	 return false;
	 }
	 public bool InsertColumn(string key, string colname, byte[] colvalue)
	 {
	 TTransport m_socket = null;
	 TTransport m_trans = null;
	 TProtocol m_proto = null;
	 try
	 {
	 m_socket = new TSocket(m_host, m_port);
	 m_trans = new TFramedTransport(m_socket);
	 m_proto = new TBinaryProtocol(m_trans);
	 m_trans.Open();
	 Cassandra.Client cass = new Cassandra.Client(m_proto);
	 cass.set_keyspace(m_space);
	 ColumnParent cparent = new ColumnParent();
	 cparent.Column_family = m_family;
	 SliceRange sr = new SliceRange();
	 sr.Start = Encoding.UTF8.GetBytes("");
	 sr.Finish = Encoding.UTF8.GetBytes("");
	 SlicePredicate sp = new SlicePredicate();
	 sp.Slice_range = sr;
	 sp.__isset.slice_range = true; // set __isset for the columns instead if you use them
	 KeyRange range = new KeyRange();
	 range.Start_key = Encoding.UTF8.GetBytes(key);
	 range.End_key = Encoding.UTF8.GetBytes(key);
	 range.__isset.start_key = true;
	 range.__isset.end_key = true;
	 List<KeySlice> results = cass.get_range_slices(cparent, sp, range, ConsistencyLevel.ONE);
	 Column c = new Column();
	 c.Name = Encoding.UTF8.GetBytes(colname);
	 c.Value = colvalue;
	 c.__isset.value = true;
	 if (results != null && results.Count > 0)
	 {
	 c.Timestamp = results[0].Columns[0].Column.Timestamp;
	 }
	 else
	 {
	 c.Timestamp = DateTime.Now.Ticks;
	 }
	 c.__isset.timestamp = true;
	 // insert the "name" column
	 cass.insert(Encoding.UTF8.GetBytes(key), cparent, c, ConsistencyLevel.ONE);
	 return true;
	 }
	 catch (TTransportException te)
	 {
	 Console.WriteLine("TTransportException: " + te);
	 }
	 catch (InvalidRequestException ire)
	 {
	 Console.WriteLine("InvalidRequestException: " + ire);
	 }
	 catch (NotFoundException nfe)
	 {
	 Console.WriteLine("NotFoundException: " + nfe);
	 }
	 catch (UnavailableException ue)
	 {
	 Console.WriteLine("UnavailableException: " + ue);
	 }
	 catch (Exception ex)
	 {
	 Console.WriteLine(ex);
	 }
	 finally
	 {
	 if (m_trans != null)
	 {
	 m_trans.Close();
	 }
	 }
	 return false;
	 }
	 public bool InsertColumn(string key, string colname, byte[] colvalue, long timestamp)
	 {
	 if (timestamp <= 0)
	 {
	 return InsertColumn(key, colname, colvalue);
	 }
	 TTransport m_socket = null;
	 TTransport m_trans = null;
	 TProtocol m_proto = null;
	 try
	 {
	 m_socket = new TSocket(m_host, m_port);
	 m_trans = new TFramedTransport(m_socket);
	 m_proto = new TBinaryProtocol(m_trans);
	 m_trans.Open();
	 Cassandra.Client cass = new Cassandra.Client(m_proto);
	 cass.set_keyspace(m_space);
	 ColumnParent cparent = new ColumnParent();
	 cparent.Column_family = m_family;
	 Column c = new Column();
	 c.Name = Encoding.UTF8.GetBytes(colname);
	 c.Value = colvalue;
	 c.__isset.value = true;
	 c.Timestamp = timestamp;
	 c.__isset.timestamp = true;
	 // insert the "name" column
	 cass.insert(Encoding.UTF8.GetBytes(key), cparent, c, ConsistencyLevel.ONE);
	 // insert another column, "JobId"
	 return true;
	 }
	 catch (TTransportException te)
	 {
	 Console.WriteLine("TTransportException: " + te);
	 }
	 catch (InvalidRequestException ire)
	 {
	 Console.WriteLine("InvalidRequestException: " + ire);
	 }
	 catch (NotFoundException nfe)
	 {
	 Console.WriteLine("NotFoundException: " + nfe);
	 }
	 catch (UnavailableException ue)
	 {
	 Console.WriteLine("UnavailableException: " + ue);
	 }
	 catch (Exception ex)
	 {
	 Console.WriteLine(ex);
	 }
	 finally
	 {
	 if (m_trans != null)
	 {
	 m_trans.Close();
	 }
	 }
	 return false;
	 }
	 public byte[] FetchColumn(string key, string colname)
	 {
	 byte[] colvalue = null;
	 TTransport m_socket = null;
	 TTransport m_trans = null;
	 TProtocol m_proto = null;
	 try
	 {
	 m_socket = new TSocket(m_host, m_port);
	 m_trans = new TFramedTransport(m_socket);
	 m_proto = new TBinaryProtocol(m_trans);
	 m_trans.Open();
	 Cassandra.Client cass = new Cassandra.Client(m_proto);
	 cass.set_keyspace(m_space);
	 ColumnPath cp = new ColumnPath();
	 cp.__isset.column = true; // this must be set of you'll get an error re: Padraig O'Sullivan
	 cp.Column = Encoding.UTF8.GetBytes(colname);
	 cp.Column_family = m_family;
	 cp.Super_column = Encoding.UTF8.GetBytes("");
	 ColumnOrSuperColumn sc = cass.get(Encoding.UTF8.GetBytes(key), cp, ConsistencyLevel.ONE);
	 colvalue = sc.Column.Value;
	 }
	 catch (TTransportException te)
	 {
	 Console.WriteLine("TTransportException: " + te);
	 }
	 catch (InvalidRequestException ire)
	 {
	 Console.WriteLine("InvalidRequestException: " + ire);
	 }
	 catch (NotFoundException nfe)
	 {
	 Console.WriteLine("NotFoundException: " + nfe);
	 }
	 catch (UnavailableException ue)
	 {
	 Console.WriteLine("UnavailableException: " + ue);
	 }
	 catch (Exception ex)
	 {
	 Console.WriteLine(ex);
	 }
	 finally
	 {
	 if (m_trans != null)
	 {
	 m_trans.Close();
	 }
	 }
	 return colvalue;
	 }
	 public bool RemoveColumn(string key)
	 {
	 TTransport m_socket = null;
	 TTransport m_trans = null;
	 TProtocol m_proto = null;
	 try
	 {
	 m_socket = new TSocket(m_host, m_port);
	 m_trans = new TFramedTransport(m_socket);
	 m_proto = new TBinaryProtocol(m_trans);
	 m_trans.Open();
	 Cassandra.Client cass = new Cassandra.Client(m_proto);
	 cass.set_keyspace(m_space);
	 ColumnParent cparent = new ColumnParent();
	 cparent.Column_family = m_family;
	 // get the entire row for a key
	 SliceRange sr = new SliceRange();
	 sr.Start = Encoding.UTF8.GetBytes("");
	 sr.Finish = Encoding.UTF8.GetBytes("");
	 SlicePredicate sp = new SlicePredicate();
	 sp.Slice_range = sr;
	 sp.__isset.slice_range = true; // set __isset for the columns instead if you use them
	 KeyRange range = new KeyRange();
	 range.Start_key = Encoding.UTF8.GetBytes(key);
	 range.End_key = Encoding.UTF8.GetBytes(key);
	 range.__isset.start_key = true;
	 range.__isset.end_key = true;
	 List<KeySlice> results = cass.get_range_slices(cparent, sp, range, ConsistencyLevel.ONE);
	 ColumnPath cp = new ColumnPath();
	 cp.__isset.column = true; // this must be set of you'll get an error re: Padraig O'Sullivan
	 foreach (KeySlice result in results)
	 {
	 foreach (ColumnOrSuperColumn csc in result.Columns)
	 {
	 cp.Column = csc.Column.Name;
	 cp.Column_family = m_family;
	 cp.Super_column = Encoding.UTF8.GetBytes("");
	 cass.remove(Encoding.UTF8.GetBytes(key), cp, csc.Column.Timestamp, ConsistencyLevel.ALL);
	 }
	 }
	 return true;
	 }
	 catch (TTransportException te)
	 {
	 Console.WriteLine("TTransportException: " + te);
	 }
	 catch (InvalidRequestException ire)
	 {
	 Console.WriteLine("InvalidRequestException: " + ire);
	 }
	 catch (NotFoundException nfe)
	 {
	 Console.WriteLine("NotFoundException: " + nfe);
	 }
	 catch (UnavailableException ue)
	 {
	 Console.WriteLine("UnavailableException: " + ue);
	 }
	 catch (Exception ex)
	 {
	 Console.WriteLine(ex);
	 }
	 finally
	 {
	 if (m_trans != null)
	 {
	 m_trans.Close();
	 }
	 }
	 return false;

	 }
	 public long FetchTimestamp(string key)
	 {
	 long timestamp = 0;
	 TTransport m_socket = null;
	 TTransport m_trans = null;
	 TProtocol m_proto = null;
	 try
	 {
	 m_socket = new TSocket(m_host, m_port);
	 m_trans = new TFramedTransport(m_socket);
	 m_proto = new TBinaryProtocol(m_trans);
	 m_trans.Open();
	 Cassandra.Client cass = new Cassandra.Client(m_proto);
	 cass.set_keyspace(m_space);
	 ColumnParent cparent = new ColumnParent();
	 cparent.Column_family = m_family;
	 SliceRange sr = new SliceRange();
	 sr.Start = Encoding.UTF8.GetBytes("");
	 sr.Finish = Encoding.UTF8.GetBytes("");
	 SlicePredicate sp = new SlicePredicate();
	 sp.Slice_range = sr;
	 sp.__isset.slice_range = true; // set __isset for the columns instead if you use them
	 KeyRange range = new KeyRange();
	 range.Start_key = Encoding.UTF8.GetBytes(key);
	 range.End_key = Encoding.UTF8.GetBytes(key);
	 range.__isset.start_key = true;
	 range.__isset.end_key = true;

	 List<KeySlice> results = cass.get_range_slices(cparent, sp, range, ConsistencyLevel.ONE);
	 if (results != null && results.Count > 0)
	 {
	 timestamp = results[0].Columns[0].Column.Timestamp;
	 }
	 }
	 catch (TTransportException te)
	 {
	 Console.WriteLine("TTransportException: " + te);
	 }
	 catch (InvalidRequestException ire)
	 {
	 Console.WriteLine("InvalidRequestException: " + ire);
	 }
	 catch (NotFoundException nfe)
	 {
	 Console.WriteLine("NotFoundException: " + nfe);
	 }
	 catch (UnavailableException ue)
	 {
	 Console.WriteLine("UnavailableException: " + ue);
	 }
	 catch (Exception ex)
	 {
	 Console.WriteLine(ex);
	 }
	 finally
	 {
	 if (m_trans != null)
	 {
	 m_trans.Close();
	 }
	 }
	 return timestamp;
	 }
	 }
	}
试试其它关键字
　cassandra　
同语言下
可能有用的
若菲贡献的其它代码(2)