Examples of org.springframework.jdbc.support.rowset.SqlRowSet

Package org.springframework.jdbc.support.rowset

Examples of org.springframework.jdbc.support.rowset.SqlRowSet

org.springframework.jdbc.support.rowset.SqlRowSet
Mirror interface for javax.sql.RowSet, representing disconnected java.sql.ResultSet data.
The main difference to the standard JDBC RowSet is that an SQLException is never thrown here. This allows a SqlRowSet to be used without having to deal with checked exceptions. A SqlRowSet will throw Spring's org.springframework.jdbc.InvalidResultSetAccessException instead (when appropriate).
Note: This interface extends the java.io.Serializable marker interface. Implementations, which typically hold disconnected data, are encouraged to be actually serializable (as far as possible). @author Thomas Risberg @author Juergen Hoeller @since 1.2 @see javax.sql.RowSet @see java.sql.ResultSet @see org.springframework.jdbc.InvalidResultSetAccessException @see org.springframework.jdbc.core.JdbcTemplate#queryForRowSet

    }


    @Override
    public GenericResultsetData fillGenericResultSet(final String sql) {


        final SqlRowSet rs = this.jdbcTemplate.queryForRowSet(sql);


        final List<ResultsetColumnHeaderData> columnHeaders = new ArrayList<>();
        final List<ResultsetRowData> resultsetDataRows = new ArrayList<>();


        final SqlRowSetMetaData rsmd = rs.getMetaData();


        for (int i = 0; i < rsmd.getColumnCount(); i++) {


            final String columnName = rsmd.getColumnName(i + 1);
            final String columnType = rsmd.getColumnTypeName(i + 1);


            final ResultsetColumnHeaderData columnHeader = ResultsetColumnHeaderData.basic(columnName, columnType);
            columnHeaders.add(columnHeader);
        }


        while (rs.next()) {
            final List<String> columnValues = new ArrayList<>();
            for (int i = 0; i < rsmd.getColumnCount(); i++) {
                final String columnName = rsmd.getColumnName(i + 1);
                final String columnValue = rs.getString(columnName);
                columnValues.add(columnValue);
            }


            final ResultsetRowData resultsetDataRow = ResultsetRowData.create(columnValues);
            resultsetDataRows.add(resultsetDataRow);

View Full Code Here

    @Override
    public List<ResultsetColumnHeaderData> fillResultsetColumnHeaders(final String datatable) {


        logger.debug("::3 Was inside the fill ResultSetColumnHeader");


        final SqlRowSet columnDefinitions = getDatatableMetaData(datatable);


        final List<ResultsetColumnHeaderData> columnHeaders = new ArrayList<>();


        columnDefinitions.beforeFirst();
        while (columnDefinitions.next()) {
            final String columnName = columnDefinitions.getString("COLUMN_NAME");
            final String isNullable = columnDefinitions.getString("IS_NULLABLE");
            final String isPrimaryKey = columnDefinitions.getString("COLUMN_KEY");
            final String columnType = columnDefinitions.getString("DATA_TYPE");
            final Long columnLength = columnDefinitions.getLong("CHARACTER_MAXIMUM_LENGTH");


            final boolean columnNullable = "YES".equalsIgnoreCase(isNullable);
            final boolean columnIsPrimaryKey = "PRI".equalsIgnoreCase(isPrimaryKey);


            List<ResultsetColumnValueData> columnValues = new ArrayList<>();
            String codeName = null;
            if ("varchar".equalsIgnoreCase(columnType)) {


                final int codePosition = columnName.indexOf("_cv");
                if (codePosition > 0) {
                    codeName = columnName.substring(0, codePosition);


                    columnValues = retreiveColumnValues(codeName);
                }


            } else if ("int".equalsIgnoreCase(columnType)) {


                final int codePosition = columnName.indexOf("_cd");
                if (codePosition > 0) {
                    codeName = columnName.substring(0, codePosition);
                    columnValues = retreiveColumnValues(codeName);
                }
            }
            if (codeName == null) {
                final SqlRowSet rsValues = getDatatableCodeData(datatable, columnName);
                Integer codeId = null;
                while (rsValues.next()) {
                    codeId = rsValues.getInt("id");
                    codeName = rsValues.getString("code_name");
                }
                columnValues = retreiveColumnValues(codeId);


            }

View Full Code Here

        final List<ResultsetColumnValueData> columnValues = new ArrayList<>();


        final String sql = "select v.id, v.code_score, v.code_value from m_code m " + " join m_code_value v on v.code_id = m.id "
                + " where m.code_name = '" + codeName + "' order by v.order_position, v.id";


        final SqlRowSet rsValues = this.jdbcTemplate.queryForRowSet(sql);


        rsValues.beforeFirst();
        while (rsValues.next()) {
            final Integer id = rsValues.getInt("id");
            final String codeValue = rsValues.getString("code_value");
            final Integer score = rsValues.getInt("code_score");


            columnValues.add(new ResultsetColumnValueData(id, codeValue, score));
        }


        return columnValues;

View Full Code Here


        final List<ResultsetColumnValueData> columnValues = new ArrayList<>();
        if (codeId != null) {
            final String sql = "select v.id, v.code_value from m_code_value v where v.code_id =" + codeId
                    + " order by v.order_position, v.id";
            final SqlRowSet rsValues = this.jdbcTemplate.queryForRowSet(sql);
            rsValues.beforeFirst();
            while (rsValues.next()) {
                final Integer id = rsValues.getInt("id");
                final String codeValue = rsValues.getString("code_value");
                columnValues.add(new ResultsetColumnValueData(id, codeValue));
            }
        }


        return columnValues;

View Full Code Here


        final String sql = "select COLUMN_NAME, IS_NULLABLE, DATA_TYPE, CHARACTER_MAXIMUM_LENGTH, COLUMN_KEY"
                + " from INFORMATION_SCHEMA.COLUMNS " + " where TABLE_SCHEMA = schema() and TABLE_NAME = '" + datatable
                + "'order by ORDINAL_POSITION";


        final SqlRowSet columnDefinitions = this.jdbcTemplate.queryForRowSet(sql);
        if (columnDefinitions.next()) { return columnDefinitions; }


        throw new DatatableNotFoundException(datatable);
    }

View Full Code Here


    private SqlRowSet getDatatableCodeData(final String datatable, final String columnName) {


        final String sql = "select mc.id,mc.code_name from m_code mc join x_table_column_code_mappings xcc on xcc.code_id = mc.id where xcc.column_alias_name='"
                + datatable.toLowerCase().replaceAll("\\s", "_") + "_" + columnName + "'";
        final SqlRowSet rsValues = this.jdbcTemplate.queryForRowSet(sql);


        return rsValues;
    }

View Full Code Here

        return perTypeProps;
    }


    private BiMap<Integer, Class<?>> loadTypes(NamedParameterJdbcOperations template) {
        String sql = "select oid, typename from type";
        SqlRowSet rowSet = template.queryForRowSet(sql, params("", ""));
        BiMap<Integer, Class<?>> types = HashBiMap.create();
        if (rowSet.first()) {
            do {
                Number oid = (Number) rowSet.getObject(1);
                String typeName = rowSet.getString(2);
                Class<?> clazz;
                try {
                    clazz = Class.forName(typeName);
                } catch (ClassNotFoundException e) {
                    throw Throwables.propagate(e);
                }
                types.put(oid.intValue(), clazz);
            } while (rowSet.next());
        }
        return types;
    }

View Full Code Here

0 1 2 3 4 5 6

TOP

Related Classes of org.springframework.jdbc.support.rowset.SqlRowSet

cn.org.rapid_framework.spring.beans.factory.config.JdbcPlaceholderConfigurer

com.jeecms.cms.dao.assist.impl.CmsDataBackDaoImpl

com.jeecms.cms.dao.assist.impl.CmsDataDaoImpl

com.jverstry.Controller.MyController

com.salesforce.dataloader.dao.database.DatabaseTestUtil

com.services.otg.db.TrackingTemplate

it.pdor.gestionePratica.dao.jdbc.GestionePraticaDaoJdbcImpl

org.beangle.ems.avatar.service.DataBaseAvatarBase

org.beangle.webapp.avatar.service.DataBaseAvatarBase

org.geoserver.jdbcconfig.internal.DbMappings

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.