spring data mongodb 提供的MongoTemplate 模板，进行Aggregation操作实践

使用spring data mongodb 提供的MongoTemplate 模板，进行Aggregation操作实践

public class FlowSizeAggregateTest

{
public static void main(String[] args) throws Exception
{
ApplicationContext context = new ClassPathXmlApplicationContext(
"classpath*:META-INF/spring/*.xml");

MongoTemplate mongoTemplate = (org.springframework.data.mongodb.core.MongoTemplate) context
.getBean(MongoTemplate.class);

// Criteria criteria =
// Criteria.where("userName").is("123123@123.com");
Aggregation aggregation = Aggregation.newAggregation(Aggregation
.group("userName").sum("flowSize").as("tatoalFlowSize").sum("amount").as("totalAmount"));
AggregationResults<User> aggRes = mongoTemplate.aggregate(aggregation,
"flow_2016_10", User.class);
List<User> listRes = aggRes.getMappedResults();

for (User user : listRes)
{
System.out.println(user);
}
System.out.println(listRes.size());
}
}

class User implements Serializable

{

/**
 * 
 */
private static final long serialVersionUID = -6420217644123680385L;

private String _id;

private String tatoalFlowSize;

private Double totalAmount;

public String get_id()
{
return _id;
}
public void set_id(String _id)
{
this._id = _id;
}
public String getTatoalFlowSize()
{
return tatoalFlowSize;
}
public void setTatoalFlowSize(String tatoalFlowSize)
{
this.tatoalFlowSize = tatoalFlowSize;
}
public Double getTotalAmount()
{
return totalAmount;
}
public void setTotalAmount(Double totalAmount)
{
this.totalAmount = totalAmount;
}
@Override
public String toString()
{
return "User [_id=" + _id + ", tatoalFlowSize=" + tatoalFlowSize
+ ", totalAmount=" + totalAmount + "]";
}

}

使用spring data mongodb 提供的MongoTemplate 模板，进行Aggregation操作实践

public class FlowSizeAggregateTest

{
public static void main(String[] args) throws Exception
{

ApplicationContext context = new ClassPathXmlApplicationContext(
"classpath*:META-INF/spring/*.xml");

MongoTemplate mongoTemplate = (org.springframework.data.mongodb.core.MongoTemplate) context
.getBean(MongoTemplate.class);

// Criteria criteria =
// Criteria.where("userName").is("123123@123.com");
Aggregation aggregation = Aggregation.newAggregation(Aggregation
.group("userName").sum("flowSize").as("tatoalFlowSize").sum("amount").as("totalAmount"));
AggregationResults<User> aggRes = mongoTemplate.aggregate(aggregation,
"flow_2016_10", User.class);
List<User> listRes = aggRes.getMappedResults();

for (User user : listRes)
{
System.out.println(user);
}
System.out.println(listRes.size());
}
}

class User implements Serializable

{

/**
 * 
 */
private static final long serialVersionUID = -6420217644123680385L;

private String _id;

private String tatoalFlowSize;

private Double totalAmount;

public String get_id()
{
return _id;
}

public void set_id(String _id)
{
this._id = _id;
}

public String getTatoalFlowSize()
{
return tatoalFlowSize;
}

public void setTatoalFlowSize(String tatoalFlowSize)
{
this.tatoalFlowSize = tatoalFlowSize;
}

public Double getTotalAmount()
{
return totalAmount;
}

public void setTotalAmount(Double totalAmount)
{
this.totalAmount = totalAmount;
}

@Override
public String toString()
{
return "User [_id=" + _id + ", tatoalFlowSize=" + tatoalFlowSize
+ ", totalAmount=" + totalAmount + "]";
}

}