Application: gvSIG desktop

	static IFeature createFeatureFromBinaryCursor(JDBCStore store, ResultSet rs, DBFeatureType featureType) throws ReadException {

		PostgresqlBinFeature feature=null;

		Object[] pk;

		try {

			pk = getPkFromResulsetBinary(rs, featureType);

			feature=new PostgresqlBinFeature(featureType,store,pk);

			Iterator iter = featureType.iterator();

			IGeometry geom = null;

			while (iter.hasNext()) {

				JDBCAttributeDescriptor fad=(JDBCAttributeDescriptor)iter.next();

				feature.set(fad.getName(), getFieldValueFromBinaryCursor(rs, fad));

			}

			return feature;

		} catch (java.sql.SQLException e) {

			throw new ReadException("CreateFeature",e);

		}

	}

	static Object getFieldValueFromBinaryCursor(ResultSet aRs, JDBCAttributeDescriptor attrDescriptor) throws java.sql.SQLException {

		int fieldId = attrDescriptor.ordinal();

		int sqlType = attrDescriptor.getSqlType();

		byte[] byteBuf = aRs.getBytes(fieldId+1);

		if (byteBuf == null)

			return null;

		else {

			ByteBuffer buf = ByteBuffer.wrap(byteBuf);

			switch (sqlType) {

			case Types.VARCHAR:

				//FIXME Error

				return aRs.getString(fieldId);

//				return new String(buf.toString());

			case Types.FLOAT:

				return new Float(buf.getFloat());

			case Types.DOUBLE:

				return new Double(buf.getDouble());

			case Types.REAL:

				return new Float(buf.getFloat());

			case Types.INTEGER:

				return new Integer(buf.getInt());

			case Types.BIGINT:

				return new Long(buf.getLong());

			case Types.BIT:

				return new Boolean(byteBuf[0] == 1);

			case Types.BOOLEAN:

				return new Boolean(aRs.getBoolean(fieldId));

			case Types.DATE:

				long daysAfter2000 = buf.getInt() + 1;

				long msecs = daysAfter2000*24*60*60*1000;

				long real_msecs_date1 = (long) (XTypes.NUM_msSecs2000 + msecs);

				Date realDate1 = new Date(real_msecs_date1);

				return realDate1;

			case Types.TIME:

				// TODO:

				// throw new RuntimeException("TIME type not implemented yet");

				return "NOT IMPLEMENTED YET";

			case Types.TIMESTAMP:

				double segsReferredTo2000 = buf.getDouble();

				long real_msecs = (long) (XTypes.NUM_msSecs2000 + segsReferredTo2000*1000);

				Timestamp valTimeStamp = new Timestamp(real_msecs);

				return valTimeStamp;

			case Types.NUMERIC:

				// System.out.println(metaData.getColumnName(fieldId) + " "

				// + metaData.getColumnClassName(fieldId));

				short ndigits = buf.getShort();

				short weight = buf.getShort();

				short sign = buf.getShort();

				short dscale = buf.getShort();

				String strAux;

				if (sign == 0)

					strAux = "+";

				else

					strAux = "-";

				for (int iDigit = 0; iDigit < ndigits; iDigit++) {

					short digit = buf.getShort();

					strAux = strAux + digit;

					if (iDigit == weight)

						strAux = strAux + ".";

				}

				strAux = strAux + "0";

				BigDecimal dec;

				dec = new BigDecimal(strAux);

				// System.out.println(ndigits + "_" + weight + "_" + dscale

				// + "_" + strAux);

				// System.out.println(strAux + " Big= " + dec);

				return new Double(dec.doubleValue());

			default:

				if (attrDescriptor.getDataType() == IFeatureAttributeDescriptor.TYPE_GEOMETRY){

					if (byteBuf == null)

						return null;

					return wkbParser.parse(byteBuf);

				}

				return null;

			}

		}

	}

	static Object[] getPkFromResulsetBinary(ResultSet rs, DBFeatureType featureType) throws java.sql.SQLException{

		String[] fieldsId = featureType.getFieldsId();

		Object[] result = new Object[fieldsId.length];

		for (int i=0;i<fieldsId.length;i++){

			result[i] = getFieldValueFromBinaryCursor(

					rs,

					(JDBCAttributeDescriptor)featureType.get(

							featureType.getFieldIndex(fieldsId[i])

							)

				);

		}

		return result;

	}

	static IFeature createFeature(JDBCStore store,ResultSet rs,DBFeatureType featureType) throws ReadException{

		JDBCFeature feature=null;

		Object[] pk;

		try {

			pk = getPkFromResulset(rs, featureType);

			feature=new PostgresqlBinFeature(featureType,store,pk);

			Iterator iter = featureType.iterator();

			IGeometry geom = null;

			while (iter.hasNext()) {

				IFeatureAttributeDescriptor fad=(IFeatureAttributeDescriptor)iter.next();

				if (fad.getDataType().equals(IFeatureAttributeDescriptor.TYPE_GEOMETRY)) {

					byte[] data = rs.getBytes(fad.getName());

					if (data == null) {

						geom = null;

					} else{

						geom = wkbParser.parse(data);

					}

					feature.setGeometry(fad.getName(),geom);

				} else {

					feature.set(fad.getName(), rs.getObject(fad.getName()));

				}

			}

			return feature;

		} catch (java.sql.SQLException e) {

			throw new ReadException("CreateFeature",e);

		}

	}

	static String getFliterForID(DBFeatureType featureType, Object[] featureKey) {

		// TODO Auto-generated method stub

		return null;

	}

	protected static String getFliterForID(DBFeatureType fType, IFeature feature){

		return getFliterForID(fType, getPkFromFeature(feature,fType));

	}

	protected static Object[] getPkFromResulset(ResultSet rs, DBFeatureType featureType) throws java.sql.SQLException{

		String[] fieldsId = featureType.getFieldsId();

		Object[] result = new Object[fieldsId.length];

		for (int i=0;i<fieldsId.length;i++){

			result[i] = rs.getObject(fieldsId[i]);

		}

		return result;

	}

	protected static Object[] getPkFromFeature(IFeature feature, DBFeatureType featureType){

		String[] fieldsId = featureType.getFieldsId();

		Object[] result = new Object[fieldsId.length];

		for (int i=0;i<fieldsId.length;i++){

			result[i] = feature.get(fieldsId[i]);

		}

		return result;

	}