java实现mysql传入list<T>批量统计type字段包含指定值的个数,返回list<map>
时间: 2024-05-10 17:19:10 浏览: 187
数据的批量导入之java实现
假设你已经有了一个Java类`T`,它对应着MySQL中的一张表,其中有一个名为`type`的字段。可以按照如下步骤实现传入`List<T>`批量统计`type`字段包含指定值的个数,并返回`List<Map>`的功能:
1. 引入MySQL的JDBC驱动程序,连接到MySQL数据库。
```java
Class.forName("com.mysql.jdbc.Driver");
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydb", "username", "password");
```
2. 构造SQL语句,使用`IN`关键字实现批量查询。
```java
StringBuilder sql = new StringBuilder("SELECT type, COUNT(*) AS count FROM mytable WHERE type IN (");
for (int i = 0; i < types.size(); i++) {
sql.append("?");
if (i < types.size() - 1) {
sql.append(",");
}
}
sql.append(") GROUP BY type");
```
其中,`types`是包含指定值的`List`,`mytable`是MySQL中对应的表名。
3. 使用`PreparedStatement`对象执行SQL语句,替换占位符参数,得到结果集。
```java
PreparedStatement ps = conn.prepareStatement(sql.toString());
for (int i = 0; i < types.size(); i++) {
ps.setString(i + 1, types.get(i));
}
ResultSet rs = ps.executeQuery();
```
4. 将结果集转换为`List<Map>`的格式。
```java
List<Map<String, Object>> result = new ArrayList<>();
while (rs.next()) {
Map<String, Object> map = new HashMap<>();
map.put("type", rs.getString("type"));
map.put("count", rs.getInt("count"));
result.add(map);
}
```
5. 关闭数据库连接,返回结果集。
```java
rs.close();
ps.close();
conn.close();
return result;
```
完整的Java代码如下:
```java
public List<Map<String, Object>> countTypes(List<T> list, List<String> types) throws ClassNotFoundException, SQLException {
Class.forName("com.mysql.jdbc.Driver");
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydb", "username", "password");
StringBuilder sql = new StringBuilder("SELECT type, COUNT(*) AS count FROM mytable WHERE type IN (");
for (int i = 0; i < types.size(); i++) {
sql.append("?");
if (i < types.size() - 1) {
sql.append(",");
}
}
sql.append(") GROUP BY type");
PreparedStatement ps = conn.prepareStatement(sql.toString());
for (int i = 0; i < types.size(); i++) {
ps.setString(i + 1, types.get(i));
}
ResultSet rs = ps.executeQuery();
List<Map<String, Object>> result = new ArrayList<>();
while (rs.next()) {
Map<String, Object> map = new HashMap<>();
map.put("type", rs.getString("type"));
map.put("count", rs.getInt("count"));
result.add(map);
}
rs.close();
ps.close();
conn.close();
return result;
}
```
需要注意的是,这里使用了`PreparedStatement`对象来执行SQL语句,可以防止SQL注入攻击,并且提高了SQL语句的执行效率。同时,为了简化示例,这里使用了`Map`来保存每个`type`和对应的个数,实际开发中可以根据需要修改返回结果的格式。
阅读全文