package com.thunisoft.zsj.fusion.row; import org.junit.jupiter.api.Test; import org.springframework.jdbc.core.ColumnMapRowMapper; import org.springframework.jdbc.datasource.DriverManagerDataSource; import java.sql.*; import java.util.Map; import java.util.Set; public class MapperTest { @Test public void colmappertest() throws SQLException { DriverManagerDataSource ds = new DriverManagerDataSource("jdbc:postgresql://172.16.32.40:6543/zsj_abu?charSet=utf8","zsj","123456"); ds.setDriverClassName("org.postgresql.Driver"); Connection conn = ds.getConnection(); Statement stmt = conn.createStatement(); ResultSet rs = stmt.executeQuery("select * from person.abu_1"); //从数据库中预先加载的记录条数 rs.setFetchSize(10); ColumnMapRowMapper rowMapper = new ColumnMapRowMapper(); int row = 0; while(rs.next()){ Map<String, Object> raw = rowMapper.mapRow(rs,row++); System.out.println("----------------------"+row+"------------------------"); Set<Map.Entry<String, Object>> entrySet = raw.entrySet(); for (Map.Entry<String, Object> entry : entrySet) { System.out.println(String.format("key:%s,value:%s",entry.getKey(),entry.getValue())); } } rs.close(); stmt.close(); conn.close(); } }
原文:https://www.cnblogs.com/abuduri/p/13343363.html