public class LargeTableDAO {
private String connectionUrl;
private String username;
private String password;

public LargeTableDAO(String connectionUrl, String username, String password) {
this.connectionUrl = connectionUrl;
this.username = username;
this.password = password;
}

public LargeTable getById(int id) throws SQLException {
String sql = “SELECT Id, Col1, Col2 FROM fgedu.large_table WHERE Id = ?”;
try (Connection connection = DriverManager.getConnection(connectionUrl, username, password);
PreparedStatement statement = connection.prepareStatement(sql)) {
statement.setInt(1, id);
try (ResultSet resultSet = statement.executeQuery()) {
if (resultSet.next()) {
return new LargeTable(
resultSet.getInt(“Id”),
resultSet.getString(“Col1”),
resultSet.getString(“Col2”)
);
}
return null;
}
}
}

public List getAll() throws SQLException {
String sql = “SELECT Id, Col1, Col2 FROM fgedu.large_table”;
try (Connection connection = DriverManager.getConnection(connectionUrl, username, password);
PreparedStatement statement = connection.prepareStatement(sql);
ResultSet resultSet = statement.executeQuery()) {
List result = new ArrayList<>();
while (resultSet.next()) {
result.add(new LargeTable(
resultSet.getInt(“Id”),
resultSet.getString(“Col1”),
resultSet.getString(“Col2”)
));
}
return result;
}
}

public void add(LargeTable entity) throws SQLException {
String sql = “INSERT INTO fgedu.large_table (Col1, Col2) VALUES (?, ?)”;
try (Connection connection = DriverManager.getConnection(connectionUrl, username, password);
PreparedStatement statement = connection.prepareStatement(sql)) {
statement.setString(1, entity.getCol1());
statement.setString(2, entity.getCol2());
statement.executeUpdate();
}
}

public void update(LargeTable entity) throws SQLException {
String sql = “UPDATE fgedu.large_table SET Col1 = ?, Col2 = ? WHERE Id = ?”;
try (Connection connection = DriverManager.getConnection(connectionUrl, username, password);
PreparedStatement statement = connection.prepareStatement(sql)) {
statement.setString(1, entity.getCol1());
statement.setString(2, entity.getCol2());
statement.setInt(3, entity.getId());
statement.executeUpdate();
}
}

public void delete(int id) throws SQLException {
String sql = “DELETE FROM fgedu.large_table WHERE Id = ?”;
try (Connection connection = DriverManager.getConnection(connectionUrl, username, password);
PreparedStatement statement = connection.prepareStatement(sql)) {
statement.setInt(1, id);
statement.executeUpdate();
}
}
}

public class LargeTable {
private int id;
private String col1;
private String col2;

public LargeTable(int id, String col1, String col2) {
this.id = id;
this.col1 = col1;
this.col2 = col2;
}

// getters and setters
public int getId() { return id; }
public void setId(int id) { this.id = id; }
public String getCol1() { return col1; }
public void setCol1(String col1) { this.col1 = col1; }
public String getCol2() { return col2; }
public void setCol2(String col2) { this.col2 = col2; }
}

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;

public class LargeTableRepository {
private JdbcTemplate jdbcTemplate;

public LargeTableRepository(JdbcTemplate jdbcTemplate) {
this.jdbcTemplate = jdbcTemplate;
}

public LargeTable getById(int id) {
String sql = “SELECT Id, Col1, Col2 FROM fgedu.large_table WHERE Id = ?”;
return jdbcTemplate.queryForObject(sql, new Object[]{id}, (rs, rowNum) ->
new LargeTable(rs.getInt(“Id”), rs.getString(“Col1”), rs.getString(“Col2”))
);
}

public List getAll() {
String sql = “SELECT Id, Col1, Col2 FROM fgedu.large_table”;
return jdbcTemplate.query(sql, (rs, rowNum) ->
new LargeTable(rs.getInt(“Id”), rs.getString(“Col1”), rs.getString(“Col2”))
);
}

public void add(LargeTable entity) {
String sql = “INSERT INTO fgedu.large_table (Col1, Col2) VALUES (?, ?)”;
jdbcTemplate.update(sql, entity.getCol1(), entity.getCol2());
}

public void update(LargeTable entity) {
String sql = “UPDATE fgedu.large_table SET Col1 = ?, Col2 = ? WHERE Id = ?”;
jdbcTemplate.update(sql, entity.getCol1(), entity.getCol2(), entity.getId());
}

public void delete(int id) {
String sql = “DELETE FROM fgedu.large_table WHERE Id = ?”;
jdbcTemplate.update(sql, id);
}
}

org.mybatis.spring.boot
mybatis-spring-boot-starter
3.0.3

import org.apache.ibatis.annotations.*;
import java.util.List;

@Mapper
public interface LargeTableMapper {
@Select(“SELECT Id, Col1, Col2 FROM fgedu.large_table WHERE Id = #{id}”)
LargeTable getById(int id);

@Select(“SELECT Id, Col1, Col2 FROM fgedu.large_table”)
List getAll();

@Insert(“INSERT INTO fgedu.large_table (Col1, Col2) VALUES (#{col1}, #{col2})”)
void add(LargeTable entity);

@Update(“UPDATE fgedu.large_table SET Col1 = #{col1}, Col2 = #{col2} WHERE Id = #{id}”)
void update(LargeTable entity);

@Delete(“DELETE FROM fgedu.large_table WHERE Id = #{id}”)
void delete(int id);
}

执行结果：