pil3aoekg
/
javac
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

1.环境搭建完成

Browse Source 
2.相关的工具类编写完成
3.配置文件管理类编写完成
hxy
yy 9 months ago
parent 731d7ba4c1
commit 908dad413b
7 changed files with 194 additions and 142 deletions
Show Stats Download Patch File Download Diff File

24
.idea/workspace.xml
Unescape View File

@ -4,8 +4,13 @@
<option name="autoReloadType" value="ALL" />
</component>
<component name="ChangeListManager">
<list default="true" id="a7505764-040b-48e2-b2fc-8c5b579e595f" name="Default" comment="">
<list default="true" id="a7505764-040b-48e2-b2fc-8c5b579e595f" name="Default" comment="1.环境搭建完成&#10;2.相关的工具类编写完成&#10;3.配置文件管理类编写完成">
<change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
<change beforePath="$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/impl/SessionDetailDaoImpl.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/impl/SessionDetailDaoImpl.java" afterDir="false" />
<change beforePath="$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/impl/SessionRandomExtractDaoImpl.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/impl/SessionRandomExtractDaoImpl.java" afterDir="false" />
<change beforePath="$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/impl/TaskDaoImpl.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/impl/TaskDaoImpl.java" afterDir="false" />
<change beforePath="$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/impl/Top10CategoryDaoImpl.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/impl/Top10CategoryDaoImpl.java" afterDir="false" />
<change beforePath="$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/impl/Top10CategorySessionDaoImpl.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/impl/Top10CategorySessionDaoImpl.java" afterDir="false" />
</list>
<option name="SHOW_DIALOG" value="false" />
<option name="HIGHLIGHT_CONFLICTS" value="true" />
@ -28,6 +33,11 @@
</findStrings>
</component>
<component name="Git.Settings">
<option name="RECENT_BRANCH_BY_REPOSITORY">
<map>
<entry key="$PROJECT_DIR$" value="main" />
</map>
</option>
<option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$" />
</component>
<component name="GradleLocalSettings">
@ -238,6 +248,7 @@
<option name="showLibraryContents" value="true" />
</component>
<component name="PropertiesComponent">
<property name="SHARE_PROJECT_CONFIGURATION_FILES" value="true" />
<property name="SearchEverywhereHistoryKey" value="wor&#9;FILE&#9;file:///Users/youyujie/Documents/UserActionAnalyzePlatform/.idea/libraries/Maven__org_apache_curator_curator_framework_2_4_0.xml" />
<property name="WebServerToolWindowFactoryState" value="false" />
<property name="aspect.path.notification.shown" value="true" />
@ -417,7 +428,7 @@
<workItem from="1529845795654" duration="7752000" />
<workItem from="1529887211212" duration="6851000" />
<workItem from="1529994772485" duration="146000" />
<workItem from="1734353432207" duration="1879000" />
<workItem from="1734353432207" duration="2666000" />
</task>
<task id="LOCAL-00001" summary="1.环境搭建完成&#10;2.相关的工具类编写完成&#10;3.配置文件管理类编写完成">
<created>1529592741848</created>
@ -433,7 +444,14 @@
<option name="project" value="LOCAL" />
<updated>1529593229553</updated>
</task>
<option name="localTasksCounter" value="3" />
<task id="LOCAL-00003" summary="1.环境搭建完成&#10;2.相关的工具类编写完成&#10;3.配置文件管理类编写完成">
<created>1734355623186</created>
<option name="number" value="00003" />
<option name="presentableId" value="LOCAL-00003" />
<option name="project" value="LOCAL" />
<updated>1734355623186</updated>
</task>
<option name="localTasksCounter" value="4" />
<servers />
</component>
<component name="TestHistory">

43
src/main/java/cn/edu/hust/dao/factory/DaoFactory.java
Unescape View File

@ -1,35 +1,36 @@
package cn.edu.hust.dao.factory;
package cn.edu.hust.dao.factory; // 定义包名，表示这个类属于cn.edu.hust.dao.factory包
import cn.edu.hust.dao.*;
import cn.edu.hust.dao.impl.*;
import cn.edu.hust.domain.SessionDetail;
import cn.edu.hust.domain.SessionRandomExtract;
import cn.edu.hust.dao.*; // 导入cn.edu.hust.dao包下的所有类
import cn.edu.hust.dao.impl.*; // 导入cn.edu.hust.dao.impl包下的所有类
import cn.edu.hust.domain.SessionDetail; // 导入SessionDetail实体类
import cn.edu.hust.domain.SessionRandomExtract; // 导入SessionRandomExtract实体类
public class DaoFactory {
public class DaoFactory { // 定义DaoFactory类，用于创建数据访问对象的实例
/**
* 使用工厂模式
* @return
* 使用工厂模式获取TaskDao对象
* @return 返回TaskDao接口的实现类实例
*/
public static TaskDao getTaskDao()
{
return new TaskDaoImpl();
public static TaskDao getTaskDao() {
return new TaskDaoImpl(); // 创建并返回TaskDaoImpl对象
}
public static SessionAggrStatDao getSessionAggrStatDao()
{
return new SessionAggrStatDaoImpl();
public static SessionAggrStatDao getSessionAggrStatDao() {
return new SessionAggrStatDaoImpl(); // 创建并返回SessionAggrStatDaoImpl对象
}
public static SessionRandomExtractDao getSessionRandomExtractDao(){
return new SessionRandomExtractDaoImpl();
public static SessionRandomExtractDao getSessionRandomExtractDao() {
return new SessionRandomExtractDaoImpl(); // 创建并返回SessionRandomExtractDaoImpl对象
}
public static SessionDetailDao getSessionDetailDao()
{
return new SessionDetailDaoImpl();
public static SessionDetailDao getSessionDetailDao() {
return new SessionDetailDaoImpl(); // 创建并返回SessionDetailDaoImpl对象
}
public static Top10CategoryDao getTop10CategoryDao(){ return new Top10CategoryDaoImpl();}
public static Top10CategoryDao getTop10CategoryDao() {
return new Top10CategoryDaoImpl(); // 创建并返回Top10CategoryDaoImpl对象
}
public static Top10CategorySessionDao getTop10CategorySessionDao(){ return new Top10CategorySessionDaoImpl();}
public static Top10CategorySessionDao getTop10CategorySessionDao() {
return new Top10CategorySessionDaoImpl(); // 创建并返回Top10CategorySessionDaoImpl对象
}
}

75
src/main/java/cn/edu/hust/dao/impl/SessionDetailDaoImpl.java
Unescape View File

@ -1,36 +1,55 @@
package cn.edu.hust.dao.impl;
package cn.edu.hust.dao.impl; // 定义包名，表示这个类属于cn.edu.hust.dao.impl包
import cn.edu.hust.dao.SessionDetailDao;
import cn.edu.hust.domain.SessionDetail;
import cn.edu.hust.jdbc.JDBCHelper;
import cn.edu.hust.dao.SessionDetailDao; // 导入SessionDetailDao接口
import cn.edu.hust.domain.SessionDetail; // 导入SessionDetail实体类
import cn.edu.hust.jdbc.JDBCHelper; // 导入JDBCHelper类，用于数据库操作
import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;
import java.io.Serializable; // 导入Serializable接口，用于序列化
import java.util.ArrayList; // 导入ArrayList类，用于创建列表
import java.util.List; // 导入List接口
public class SessionDetailDaoImpl implements SessionDetailDao{
@Override
public void insert(SessionDetail sessionDetail) {
String sql="insert into session_detail values(?,?,?,?,?,?,?,?,?,?,?,?)";
Object[] object=new Object[]{sessionDetail.getTaskId(),sessionDetail.getUserId(),
sessionDetail.getSessinId(),sessionDetail.getPageid(),sessionDetail.getActionTime(),
sessionDetail.getSearchKeyWord(),sessionDetail.getClickCategoryId(),sessionDetail.getClickProductId()
,sessionDetail.getOrderCategoryIds(),sessionDetail.getOrderProductIds(),sessionDetail.getPayCategoryIds(),sessionDetail.getPayProductIds()};
JDBCHelper.getInstance().excuteUpdate(sql,object);
public class SessionDetailDaoImpl implements SessionDetailDao { // 定义SessionDetailDaoImpl类，实现SessionDetailDao接口
@Override // 覆盖接口中的方法
public void insert(SessionDetail sessionDetail) { // 定义insert方法，用于插入单个SessionDetail对象
String sql="insert into session_detail values(?,?,?,?,?,?,?,?,?,?,?,?,?)"; // 定义插入SQL语句
Object[] object=new Object[]{ // 创建一个对象数组，用于存储SessionDetail对象的属性值
sessionDetail.getTaskId(), // 获取任务ID
sessionDetail.getUserId(), // 获取用户ID
sessionDetail.getSessinId(), // 获取会话ID（注意：这里可能是拼写错误，应该是sessionDetail.getSessionId()）
sessionDetail.getPageid(), // 获取页面ID
sessionDetail.getActionTime(), // 获取操作时间
sessionDetail.getSearchKeyWord(), // 获取搜索关键词
sessionDetail.getClickCategoryId(), // 获取点击的分类ID
sessionDetail.getClickProductId(), // 获取点击的产品ID
sessionDetail.getOrderCategoryIds(), // 获取订单的分类IDs
sessionDetail.getOrderProductIds(), // 获取订单的产品IDs
sessionDetail.getPayCategoryIds(), // 获取支付的分类IDs
sessionDetail.getPayProductIds() // 获取支付的产品IDs
};
JDBCHelper.getInstance().excuteUpdate(sql,object); // 调用JDBCHelper的excuteUpdate方法执行SQL更新（注意：这里应该是executeUpdate）
}
@Override
public void batchInsert(List<SessionDetail> sessionDetailList) {
String sql="insert into session_detail values(?,?,?,?,?,?,?,?,?,?,?,?)";
List<Object[]> paramList=new ArrayList<Object[]>();
for (SessionDetail sessionDetail:sessionDetailList)
{
Object[] object=new Object[]{sessionDetail.getTaskId(),sessionDetail.getUserId(),
sessionDetail.getSessinId(),sessionDetail.getPageid(),sessionDetail.getActionTime(),
sessionDetail.getSearchKeyWord(),sessionDetail.getClickCategoryId(),sessionDetail.getClickProductId()
,sessionDetail.getOrderCategoryIds(),sessionDetail.getOrderProductIds(),sessionDetail.getPayCategoryIds(),sessionDetail.getPayProductIds()};
paramList.add(object);
@Override // 覆盖接口中的方法
public void batchInsert(List<SessionDetail> sessionDetailList) { // 定义batchInsert方法，用于批量插入SessionDetail对象
String sql="insert into session_detail values(?,?,?,?,?,?,?,?,?,?,?,?,?)"; // 定义插入SQL语句
List<Object[]> paramList=new ArrayList<Object[]>(); // 创建一个列表，用于存储每个SessionDetail对象的参数数组
for (SessionDetail sessionDetail:sessionDetailList) { // 遍历传入的SessionDetail对象列表
Object[] object=new Object[]{ // 创建一个对象数组，用于存储当前SessionDetail对象的属性值
sessionDetail.getTaskId(), // 获取任务ID
sessionDetail.getUserId(), // 获取用户ID
sessionDetail.getSessinId(), // 获取会话ID（注意：这里可能是拼写错误，应该是sessionDetail.getSessionId()）
sessionDetail.getPageid(), // 获取页面ID
sessionDetail.getActionTime(), // 获取操作时间
sessionDetail.getSearchKeyWord(), // 获取搜索关键词
sessionDetail.getClickCategoryId(), // 获取点击的分类ID
sessionDetail.getClickProductId(), // 获取点击的产品ID
sessionDetail.getOrderCategoryIds(), // 获取订单的分类IDs
sessionDetail.getOrderProductIds(), // 获取订单的产品IDs
sessionDetail.getPayCategoryIds(), // 获取支付的分类IDs
sessionDetail.getPayProductIds() // 获取支付的产品IDs
};
paramList.add(object); // 将参数数组添加到列表中
}
JDBCHelper.getInstance().excuteBatch(sql,paramList);
JDBCHelper.getInstance().excuteBatch(sql,paramList); // 调用JDBCHelper的excuteBatch方法执行批量SQL更新（注意：这里应该是executeBatch）
}
}

37
src/main/java/cn/edu/hust/dao/impl/SessionRandomExtractDaoImpl.java
Unescape View File

@ -1,22 +1,27 @@
package cn.edu.hust.dao.impl;
package cn.edu.hust.dao.impl; // 定义包名，表示这个类属于cn.edu.hust.dao.impl包
import cn.edu.hust.dao.SessionRandomExtractDao;
import cn.edu.hust.domain.SessionRandomExtract;
import cn.edu.hust.jdbc.JDBCHelper;
import cn.edu.hust.dao.SessionRandomExtractDao; // 导入SessionRandomExtractDao接口
import cn.edu.hust.domain.SessionRandomExtract; // 导入SessionRandomExtract实体类
import cn.edu.hust.jdbc.JDBCHelper; // 导入JDBCHelper类，用于数据库操作
import java.util.ArrayList;
import java.util.List;
import java.util.ArrayList; // 导入ArrayList类，用于创建列表
import java.util.List; // 导入List接口
public class SessionRandomExtractDaoImpl implements SessionRandomExtractDao{
@Override
public void batchInsert(List<SessionRandomExtract> sessionRandomExtractList) {
String sql="insert into session_random_extract values(?,?,?,?,?)";
List<Object[]> paramList=new ArrayList<Object[]>();
for (SessionRandomExtract sessionRandomExtract:sessionRandomExtractList) {
Object[] params=new Object[]{sessionRandomExtract.getTaskId(),sessionRandomExtract.getSessionId()
,sessionRandomExtract.getStartTime(),sessionRandomExtract.getSearchKeyWords(),sessionRandomExtract.getClick_category_ids()};
paramList.add(params);
public class SessionRandomExtractDaoImpl implements SessionRandomExtractDao { // 定义SessionRandomExtractDaoImpl类，实现SessionRandomExtractDao接口
@Override // 覆盖接口中的方法
public void batchInsert(List<SessionRandomExtract> sessionRandomExtractList) { // 定义batchInsert方法，用于批量插入SessionRandomExtract对象
String sql="insert into session_random_extract values(?,?,?,?,?)"; // 定义插入SQL语句
List<Object[]> paramList=new ArrayList<Object[]>(); // 创建一个列表，用于存储每个SessionRandomExtract对象的参数数组
for (SessionRandomExtract sessionRandomExtract:sessionRandomExtractList) { // 遍历传入的SessionRandomExtract对象列表
Object[] params=new Object[]{ // 创建一个对象数组，用于存储当前SessionRandomExtract对象的属性值
sessionRandomExtract.getTaskId(), // 获取任务ID
sessionRandomExtract.getSessionId(), // 获取会话ID
sessionRandomExtract.getStartTime(), // 获取开始时间
sessionRandomExtract.getSearchKeyWords(), // 获取搜索关键词
sessionRandomExtract.getClick_category_ids() // 获取点击的分类IDs
};
paramList.add(params); // 将参数数组添加到列表中
}
JDBCHelper.getInstance().excuteBatch(sql,paramList);
JDBCHelper.getInstance().excuteBatch(sql,paramList); // 调用JDBCHelper的excuteBatch方法执行批量SQL更新（注意：这里应该是executeBatch）
}
}

52
src/main/java/cn/edu/hust/dao/impl/TaskDaoImpl.java
Unescape View File

@ -1,38 +1,38 @@
package cn.edu.hust.dao.impl;
package cn.edu.hust.dao.impl; // 定义包名，表示这个类属于cn.edu.hust.dao.impl包
import cn.edu.hust.dao.TaskDao;
import cn.edu.hust.domain.Task;
import cn.edu.hust.jdbc.JDBCHelper;
import cn.edu.hust.dao.TaskDao; // 导入TaskDao接口
import cn.edu.hust.domain.Task; // 导入Task实体类
import cn.edu.hust.jdbc.JDBCHelper; // 导入JDBCHelper类，用于数据库操作
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.ResultSet; // 导入ResultSet类，用于处理查询结果
import java.sql.SQLException; // 导入SQLException类，用于处理SQL异常
public class TaskDaoImpl implements TaskDao{
@Override
public Task findTaskById(Long id) {
String sql="select * from task where task_id=?";
final Task task=new Task();
JDBCHelper.getInstance().excuteQuery(sql, new Object[]{id}, new JDBCHelper.QueryCallBack() {
public class TaskDaoImpl implements TaskDao { // 定义TaskDaoImpl类，实现TaskDao接口
@Override // 覆盖接口中的方法
public Task findTaskById(Long id) { // 定义findTaskById方法，根据ID查找任务
String sql="select * from task where task_id=?"; // 定义查询SQL语句
final Task task=new Task(); // 创建Task对象，用于存储查询结果
JDBCHelper.getInstance().excuteQuery(sql, new Object[]{id}, new JDBCHelper.QueryCallBack() { // 调用JDBCHelper的excuteQuery方法执行查询
@Override
public void process(ResultSet rs) {
public void process(ResultSet rs) { // 定义process方法，处理查询结果
try {
if(rs.next())
if(rs.next()) // 如果查询结果有数据
{
Long id=rs.getLong(1);
String taskName=rs.getString(2);
String createTime=rs.getString(3);
String startTime=rs.getString(4);
String finishTime=rs.getString(5);
String taskType=rs.getString(6);
String taskStatus=rs.getString(7);
String taskParam=rs.getString(8);
task.set(id,taskName,createTime,startTime,finishTime,taskType,taskStatus,taskParam);
Long id=rs.getLong(1); // 获取任务ID
String taskName=rs.getString(2); // 获取任务名称
String createTime=rs.getString(3); // 获取创建时间
String startTime=rs.getString(4); // 获取开始时间
String finishTime=rs.getString(5); // 获取完成时间
String taskType=rs.getString(6); // 获取任务类型
String taskStatus=rs.getString(7); // 获取任务状态
String taskParam=rs.getString(8); // 获取任务参数
task.set(id,taskName,createTime,startTime,finishTime,taskType,taskStatus,taskParam); // 设置Task对象的属性
}
} catch (SQLException e) {
e.printStackTrace();
} catch (SQLException e) { // 捕获并处理SQLException
e.printStackTrace(); // 打印异常堆栈信息
}
}
});
return task;
return task; // 返回Task对象
}
}

57
src/main/java/cn/edu/hust/dao/impl/Top10CategoryDaoImpl.java
Unescape View File

@ -1,36 +1,41 @@
package cn.edu.hust.dao.impl;
package cn.edu.hust.dao.impl; // 定义包名，表示这个类属于cn.edu.hust.dao.impl包
import cn.edu.hust.dao.Top10CategoryDao;
import cn.edu.hust.domain.Top10Category;
import cn.edu.hust.jdbc.JDBCHelper;
import cn.edu.hust.dao.Top10CategoryDao; // 导入Top10CategoryDao接口
import cn.edu.hust.domain.Top10Category; // 导入Top10Category实体类
import cn.edu.hust.jdbc.JDBCHelper; // 导入JDBCHelper类，用于数据库操作
import java.util.ArrayList;
import java.util.List;
import java.util.ArrayList; // 导入ArrayList类，用于创建列表
import java.util.List; // 导入List接口
public class Top10CategoryDaoImpl implements Top10CategoryDao {
@Override
public void insert(Top10Category top10Category) {
String sql="insert into top10_category values(?,?,?,?,?)";
Object[] params=new Object[]{
top10Category.getTaskId(),top10Category.getCategoryId(),top10Category.getCategoryId(),
top10Category.getClickCount(),top10Category.getOrderCount(),top10Category.getPayCount()
public class Top10CategoryDaoImpl implements Top10CategoryDao { // 定义Top10CategoryDaoImpl类，实现Top10CategoryDao接口
@Override // 覆盖接口中的方法
public void insert(Top10Category top10Category) { // 定义insert方法，用于插入单个Top10Category对象
String sql="insert into top10_category values(?,?,?,?,?)"; // 定义插入SQL语句
Object[] params=new Object[]{ // 创建一个对象数组，用于存储Top10Category对象的属性值
top10Category.getTaskId(), // 获取任务ID
top10Category.getCategoryId(), // 获取分类ID（注意：这里代码中重复了两次，可能是错误）
top10Category.getCategoryId(), // 重复的分类ID
top10Category.getClickCount(), // 获取点击次数
top10Category.getOrderCount(), // 获取订单次数
top10Category.getPayCount() // 获取支付次数
};
JDBCHelper.getInstance().excuteUpdate(sql,params);
JDBCHelper.getInstance().excuteUpdate(sql,params); // 调用JDBCHelper的excuteUpdate方法执行SQL更新（注意：这里应该是executeUpdate）
}
@Override
public void batchInsert(List<Top10Category> top10CategoryList) {
String sql="insert into top10_category values(?,?,?,?,?)";
List<Object[]> paramList=new ArrayList<Object[]>();
for (Top10Category top10Category:top10CategoryList)
{
Object[] params=new Object[]{
top10Category.getTaskId(),top10Category.getCategoryId(),
top10Category.getClickCount(),top10Category.getOrderCount(),top10Category.getPayCount()
@Override // 覆盖接口中的方法
public void batchInsert(List<Top10Category> top10CategoryList) { // 定义batchInsert方法，用于批量插入Top10Category对象
String sql="insert into top10_category values(?,?,?,?,?)"; // 定义插入SQL语句
List<Object[]> paramList=new ArrayList<Object[]>(); // 创建一个列表，用于存储每个Top10Category对象的参数数组
for (Top10Category top10Category:top10CategoryList) { // 遍历传入的Top10Category对象列表
Object[] params=new Object[]{ // 创建一个对象数组，用于存储当前Top10Category对象的属性值
top10Category.getTaskId(), // 获取任务ID
top10Category.getCategoryId(), // 获取分类ID
top10Category.getClickCount(), // 获取点击次数
top10Category.getOrderCount(), // 获取订单次数
top10Category.getPayCount() // 获取支付次数
};
paramList.add(params);
paramList.add(params); // 将参数数组添加到列表中
}
JDBCHelper.getInstance().excuteBatch(sql,paramList);
JDBCHelper.getInstance().excuteBatch(sql,paramList); // 调用JDBCHelper的excuteBatch方法执行批量SQL更新（注意：这里应该是executeBatch）
}
}

36
src/main/java/cn/edu/hust/dao/impl/Top10CategorySessionDaoImpl.java
Unescape View File

@ -1,24 +1,28 @@
package cn.edu.hust.dao.impl;
package cn.edu.hust.dao.impl; // 定义包名，表示这个类属于cn.edu.hust.dao.impl包
import cn.edu.hust.dao.Top10CategorySessionDao;
import cn.edu.hust.domain.Top10CategorySession;
import cn.edu.hust.jdbc.JDBCHelper;
import cn.edu.hust.dao.Top10CategorySessionDao; // 导入Top10CategorySessionDao接口
import cn.edu.hust.domain.Top10CategorySession; // 导入Top10CategorySession实体类
import cn.edu.hust.jdbc.JDBCHelper; // 导入JDBCHelper类，用于数据库操作
import java.util.ArrayList;
import java.util.List;
import java.util.ArrayList; // 导入ArrayList类，用于创建列表
import java.util.List; // 导入List接口
public class Top10CategorySessionDaoImpl implements Top10CategorySessionDao
public class Top10CategorySessionDaoImpl implements Top10CategorySessionDao // 定义Top10CategorySessionDaoImpl类，实现Top10CategorySessionDao接口
{
@Override
public void batchInsert(List<Top10CategorySession> top10CategorySessionList) {
String sql="insert into top10_category_session values(?,?,?,?)";
List<Object[]> paramList=new ArrayList<Object[]>();
for(Top10CategorySession top10CategorySession:top10CategorySessionList)
@Override // 覆盖接口中的方法
public void batchInsert(List<Top10CategorySession> top10CategorySessionList) { // 定义batchInsert方法，用于批量插入Top10CategorySession对象
String sql="insert into top10_category_session values(?,?,?,?)"; // 定义插入SQL语句
List<Object[]> paramList=new ArrayList<Object[]>(); // 创建一个列表，用于存储每个Top10CategorySession对象的参数数组
for(Top10CategorySession top10CategorySession:top10CategorySessionList) // 遍历传入的Top10CategorySession对象列表
{
Object[] param=new Object[]{top10CategorySession.getTaskId(),top10CategorySession.getCategoryId(),
top10CategorySession.getSessionId(),top10CategorySession.getClickCount()};
paramList.add(param);
Object[] param=new Object[]{ // 创建一个对象数组，用于存储当前Top10CategorySession对象的属性值
top10CategorySession.getTaskId(), // 获取任务ID
top10CategorySession.getCategoryId(), // 获取分类ID
top10CategorySession.getSessionId(), // 获取会话ID
top10CategorySession.getClickCount() // 获取点击次数
};
paramList.add(param); // 将参数数组添加到列表中
}
JDBCHelper.getInstance().excuteBatch(sql,paramList);
JDBCHelper.getInstance().excuteBatch(sql,paramList); // 调用JDBCHelper的excuteBatch方法执行批量SQL更新（注意：这里应该是executeBatch）
}
}
Write Preview
Loading…
Cancel
Save