@Service("accessLogService")
@Transactional
public class LogMessageServiceImpl extends BaseDaoServiceImpl<AccessLogMessage,Long> implements LogMessageService{
 @Autowired
 SplitHibernateInterceptor splitInter;
 @Autowired
 public BaseDaoImpl<AccessLogMessage> baseDao;
 /**
  * 根据当前月份
  */
 @Override
 public void addLog(AccessLogMessage message) {
  //要拦截的目标数据库名称
  splitInter.setTargetTableName("accesslog_message");
  //月份从0计算
  int month = Calendar.getInstance().get(Calendar.MONTH);
  if(month==0){
   //1月份
   baseDao.save(message);
  }else{
   splitInter.setSubTableName("accesslog_message"+month);
   SessionFactory sf= baseDao.getSessionFactory();
   Session session = sf.openSession(splitInter);
   try{
    session.save(message);
   }finally{
    session.close();
   }
  }
  
 }
}

@Service("splitInter")
public class SplitHibernateInterceptor extends EmptyInterceptor {
 private static final long serialVersionUID = 2293562313992510554L;

 private String targetTableName;// 目标母表名
 private String subTableName;// 操作子表名 ,与目标结构一样

 public SplitHibernateInterceptor() {
 }

 public java.lang.String onPrepareStatement(java.lang.String sql) {
  sql = sql.toLowerCase();
  sql = sql.replaceAll(targetTableName, subTableName);
  return sql;

 }

 public String getTargetTableName() {
  return targetTableName;
 }

 public void setTargetTableName(String targetTableName) {
  this.targetTableName = targetTableName;
 }

 public String getSubTableName() {
  return subTableName;
 }

 public void setSubTableName(String subTableName) {
  this.subTableName = subTableName;
 }

}

@Component("baseDaoService")
@Transactional
public class BaseDaoServiceImpl<T, K extends Serializable> implements
  BaseDaoService<T, K> {

 @Autowired
 public ExtendBaseDao<T, K> extendBaseDao;

 @Override
 public void add(T t) {
  extendBaseDao.save(t);
 }

 @Override
 public void delete(T t) {
  extendBaseDao.delete(t);
 }

 @Override
 public void update(T t) {
  extendBaseDao.update(t);
 }

 @Override
 public T get(Class<T> entityClass, K k) {
  return extendBaseDao.get(entityClass, k);
 }

 @Override
 public void deleteByHql(String hql ,Object... objects) {
  extendBaseDao.delete(hql, objects);
 }

 @Override
 public List<T> query(String hql, Object... objects) {
  return extendBaseDao.list(hql, objects);
 }

 @Override
 public void marge(T t) {
  extendBaseDao.merge(t);
 }

}

@Entity
@Table(name = "ACCESSLOG_MESSAGE")
public class AccessLogMessage {
 @Id
 @GeneratedValue(strategy = GenerationType.IDENTITY)
 @Column(name = "id")
 private Long id;
 @Column(name = "requestURI", length = 250)
 private String requestURI;
 
 @Column(name = "requestTime", length = 30)
 private String requestTime;
 @Column(name = "requestParams", length = 1000)
 private String requestParams;
 @Column(name = "userName", length = 32)
 private String userName;