source: ether_eccad/trunk/ECCAD_INTERFACE/WEB-INF/src/org/medias/eccad/persistance/jdbc/GrilleTestjdbc.java @ 68

package org.medias.eccad.persistance.jdbc;

import java.sql.Connection;
import java.sql.SQLException;

import org.medias.eccad.helpers.Donnees;
import org.medias.eccad.persistance.dao.GrilleDAO;
import org.medias.eccad.persistance.exception.PersistanceException;
import org.postgresql.largeobject.LargeObject;
import org.postgresql.largeobject.LargeObjectManager;

public class GrilleTestjdbc extends GrilleDAOjdbc implements GrilleDAO {
        private Connection conn;
        
        public void connection() throws PersistanceException {
                 conn = getConnection();
        }
        
        public void disconnect() {
                closeConnection();
        }
        
        public float[][] getGrilleValue(int oid) throws PersistanceException {
                LargeObjectManager lobj = null;
                LargeObject objet_donnees = null;

                /** 
                 * retour en cas d'erreur
                 */
                if (oid == -1) {
                        float[][] tab_vide = new float[Donnees.LIGNE][Donnees.COLONNE];
                        for (int i=0; i<Donnees.LIGNE; i++)
                                for (int j=0; j<Donnees.COLONNE; j++)
                                        tab_vide[i][j] = 0;
                        return tab_vide;
                }
                        
                float[][] tab_valeur = new float[Donnees.LIGNE][Donnees.COLONNE];
                float valeur = -1;
                int i=0;
                
                try {
                        lobj = ((org.postgresql.PGConnection)conn).getLargeObjectAPI();
                } catch (SQLException e) {e.printStackTrace(); return null;}
                 
                try {
                        objet_donnees = lobj.open(oid); 
                } 
                catch (SQLException e) {
                        closeConnection();
                        throw new PersistanceException(e, "erreur recuperation large object");
                }

                byte[] b;
                
                for (i=0; i<Donnees.LIGNE; i++) {
                        
                        try {
                                
                                b = objet_donnees.read(Donnees.COLONNE*4);
                                
                                for (int j=0; j<Donnees.COLONNE*4; j+=4) {
                                        valeur = arr2float(b, j);
                                        tab_valeur[i][j/4] = valeur;
                                }
                        } 
                        catch (SQLException e) {
                                closeConnection();
                                throw new PersistanceException(e, "erreur lecture large object");
                        }
                }
                
                return null;
        }

}