- 浏览: 78319 次
- 性别:
- 来自: 广州
最新评论
-
yyf365:
想请问,你的实现中可否支持多线程?
cassandra内部API使用一2010-07-07
文章列表
public String getProductFamilyNodes(String aJsonStr)
throws ApplicationException
{
JSONObject json;
String itemId = "";
String nlsLang = "";
try
{
json = new JSONObject(aJsonStr);
itemId = json.getString(& ...
public String getHTMLAreaInfo() throws ApplicationException
{
try
{
Map<String, Object> map = iNavigationSev.getHTMLAreaInfo(ID);
JSONObject jsonOut = new JSONObject(map);
//jsonOut.put("HTMLAREA",map);
return jsonOu ...
/**
* 缓存操作实现类.
*/
@Service("cassCache")
public class CassCache implements ICassCache
{
/** 根据Key从缓存删除缓存数据.
* @param aKeyArea Key
*/
public void remove(String aKeyArea) throws ApplicationException
{
CassandraClientPool pool = CassandraClientPoolFactory.INSTAN ...
/**
* 缓存操作实现类.
*/
@Service("cassCache")
public class CassCache implements ICassCache
{
/**根据Key和column从缓存读取数据.
* @param aKeyArea Key
* @param aName column
* @return Object 缓存数据
* @throws ApplicationException ApplicationException
*/
public Object get(String ...
package com.huawei.support.cache.impl;
import static me.prettyprint.cassandra.utils.StringUtils.bytes;
import java.io.Serializable;
import java.util.HashMap;
import java.util.Map;
import me.prettyprint.cassandra.service.CassandraClient;
import me.prettyprint.cassandra.service.CassandraClientPool;
imp ...
package com.huawei.support.cache;
import java.io.Serializable;
import java.util.Map;
import com.huawei.support.exception.ApplicationException;
/**
* 缓存操作接口.
*/
public interface ICassCache
{
/**向缓存中存放数据.
* @param aKeyArea Key
* @param aName column
* @param aSerialObj 缓存对象
* @thr ...
续二的类
/**
* 从cacheConfig.xml中读取配置文件.
*/
public final class CacheConfigReader
{
/** 取得Cassandra集群服务器.
* @return String[] [返回类型说明]
*/
public String[] getCassandraClient()
{
if (null != sServerList)
{
return sServerList.clone();
}
ret ...
package com.huawei.support.cache.impl;
import java.io.File;
import java.io.IOException;
import java.net.URL;
import java.util.HashMap;
import java.util.Map;
import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.ParserConfigurationException ...
配置文件cacheConfig.xml如下:
<?xml version="1.0" encoding="UTF-8" ?>
<cacheConfig>
<!--缓存服务器集群-->
<servers id="cassandraServers">
<list>
<value>10.70.150.123:9160</value>
</list>
</serve ...
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE sqlMap PUBLIC "-//ibatis.apache.org//DTD SQL Map 2.0//EN" "http://ibatis.apache.org/dtd/sql-map-2.dtd" >
<sqlMap namespace="Navigation">
<select id="getProductLineNodes" ...
<body oncontextmenu="return false;">
//获取客户端IP,格式:"217.199.184.144";
String userIp=request.getRemoteAddr();
ORACLE按照拼音,部首,笔画排序 http://uiiang.iteye.com/blog/312324,比如:
select distinct product as item_id, t.item_name
from sup_kc_doc_unite_info
left join sup ...
6。proxool.properties
proxool.driver=oracle.jdbc.driver.OracleDriver
proxool.username=t19078
proxool.url=jdbc:oracle:thin:@szxdb10-in:1521:webdb1
proxool.alias=UAT.CHINA.HUAWEI.COM
#proxool自动侦察各个连接状态的时间间隔(毫秒),侦察到空闲的连接就马上回收,超时的销毁 默认30秒
proxool.houseKeepingSleepTime=30000
#最少保持的空闲连接数(默认2个)
proxool.proto ...
5.DBUserInfoFactory如下:
package com.huawei.support.dao;
import java.util.Hashtable;
import javax.naming.Context;
import javax.naming.Name;
import javax.naming.NamingException;
import javax.naming.Reference;
import javax.naming.spi.ObjectFactory;
import com.huawei.support.exception.ApplicationException ...
4.DBUserInfo.java如下:
package com.huawei.support.dao;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import com.huawei.it.common.encryption.exception.AppException ...
3.applicationContext.xml中:
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"
xmlns: ...