picoresultset.java

picoSQL is a SQL-based, multi-user, client/server RDBMS, released under the GPL

         setWarning(PicoDbApi.convertWarning(jdbcodbcsqlwarning));
      }
      return i;
   }

   public int getScale(int i) throws SQLException {
      int j;
      if(getPseudoCol(i) != null) {
         lastColumnNull = true;
         j = 0;
      } else {
         j = getColAttribute(i, OdbcDef.SQL_COLUMN_SCALE);
      }
      return j;
   }

   public short getShort(int i)
      throws SQLException
   {
      short word0 = 0;
      clearWarnings();
      lastColumnNull = false;
      i = mapColumn(i);
      if(getPseudoCol(i) == null)
         word0 = (short)getInt(i);
      else
         lastColumnNull = true;
      return word0;
   }

   public short getShort(String s)
      throws SQLException
   {
      return getShort(findColumn(s));
   }

   public Statement getStatement()
   {
      throw new UnsupportedOperationException();
   }

   public String getString(int i) throws SQLException {
      clearWarnings();
      lastColumnNull = false;
      i = mapColumn(i);
      if(getPseudoCol(i) != null)
      {
         lastColumnNull = true;
         return null;
      }
      int j = getMaxCharLen(i);
      if(j == -1)
         return null;
      boolean flag = false;
      int k = getColumnType(i);
      j++;
      String s = getDataString(i, j, flag);
      if(s == null)
         return s;
      int l = s.length();
      if(l == j - 1 && !flag)
         s = s.substring(0, j - 1);
      if((k == -1 || k == -4) && l == j - 1)
      {
         for(String s1 = s; s1.length() == PicoLimits.MAX_GET_DATA_LENGTH;)
         {
            s1 = getDataString(i, j, flag);
            if(s1 == null)
               break;
            if(DriverManager.getLogWriter() != null)
               DriverManager.println(s1.length() + " byte(s) read");
            if(s1.length() == j)
               s1 = s1.substring(0, j - 1);
            s = s + s1;
            if(DriverManager.getLogWriter() != null)
               DriverManager.println(s.length() + " bytes total");
         }

      }
      return s;
   }

   public String getString(String s)
      throws SQLException
   {
      return getString(findColumn(s));
   }

   public Time getTime(int i) throws SQLException {
      return new java.sql.Time (getTimestamp(i).getTime());
   }

   public Time getTime(int i, Calendar calendar) throws SQLException {      
      return new java.sql.Time (getTimestamp(i, calendar).getTime());
   }

   public Time getTime(String s) throws SQLException {
      return getTime(findColumn(s));
   }

   public Time getTime(String s, Calendar calendar) throws SQLException {
      return getTime(findColumn(s), calendar);
   }

   public Timestamp getTimestamp(int i) throws SQLException {
      Timestamp Return = null;
      clearWarnings();
      lastColumnNull = false;
      i = mapColumn(i);
      if(getPseudoCol(i) == null) {
         Return = (Timestamp) getData (i, Timestamp.class);
      } else {
         lastColumnNull = true;
      }
      return Return; 
   }

   public Timestamp getTimestamp(int i, Calendar calendar) throws SQLException {
      calendar.setTime (getTimestamp(i));
      return new Timestamp (calendar.getTime().getTime());
   }

   public Timestamp getTimestamp(String s) throws SQLException {
      return getTimestamp(findColumn(s));
   }

   public Timestamp getTimestamp(String s, Calendar calendar)
                                                        throws SQLException {
      return getTimestamp(findColumn(s), calendar);
   }

   public java.net.URL getURL (int i) throws SQLException {
      java.net.URL Return = null;
      try {
         Return = new java.net.URL (getString(i));
      } catch (java.net.MalformedURLException e) {
      }
      return Return;
   }

   public java.net.URL getURL (String n) throws SQLException {
      java.net.URL Return = null;
      try {
         Return = new java.net.URL (getString(n));
      } catch (java.net.MalformedURLException e) {
      }
      return Return;
   }

   public int getType()
   {
      throw new UnsupportedOperationException();
   }

   public InputStream getUnicodeStream(int i) throws SQLException {
      clearWarnings();
      lastColumnNull = false;
      i = mapColumn(i);
      int j = getColumnType(i);
      byte byte0 = -2;
      switch(j)
      {
      case -1: 
      case 1: // '\001'
      case 12: // '\f'
         byte0 = 1;
         break;

      }
      PicoInputStream jdbcodbcinputstream = new PicoInputStream(odbcApi, getHSTMT(), i, (short)2, byte0, ownerStatement);
      setInputStream(i, jdbcodbcinputstream);
      return jdbcodbcinputstream;
   }

   public InputStream getUnicodeStream(String s) throws SQLException {
      return getUnicodeStream(findColumn(s));
   }

   public SQLWarning getWarnings() throws SQLException {
      return lastWarning;
   }

   public void insertRow()
   {
      throw new UnsupportedOperationException();
   }

   public boolean isAfterLast()
   {
      throw new UnsupportedOperationException();
   }

   public boolean isBeforeFirst()
   {
      throw new UnsupportedOperationException();
   }

   public boolean isFirst()
   {
      throw new UnsupportedOperationException();
   }

   public boolean isLast()
   {
      throw new UnsupportedOperationException();
   }

   public boolean last()
   {
      throw new UnsupportedOperationException();
   }

   public int mapColumn(int i)
   {
      int j = i;
      if(colMappings != null)
         if(i > 0 && i <= colMappings.length)
            j = colMappings[i - 1];
         else
            j = -1;
      return j;
   }

   public void moveToCurrentRow()
   {
      throw new UnsupportedOperationException();
   }

   public void moveToInsertRow()
   {
      throw new UnsupportedOperationException();
   }

   public boolean next()
      throws SQLException
   {
      boolean flag = true;
      lastColumnNull = false;
      closeInputStreams();
      clearWarnings();
      data = null;
      try
      {
         flag = odbcApi.SQLFetch(getHSTMT());
      }
      catch(PicoSQLWarning sqlwarning)
      {
         setWarning(sqlwarning);
      }
      return flag;
   }

   public boolean previous()
   {
      throw new UnsupportedOperationException();
   }

   public void refreshRow()
   {
      throw new UnsupportedOperationException();
   }

   public boolean relative(int i)
   {
      throw new UnsupportedOperationException();
   }

   public boolean rowDeleted()
   {
      throw new UnsupportedOperationException();
   }

   public boolean rowInserted()
   {
      throw new UnsupportedOperationException();
   }

   public boolean rowUpdated()
   {
      throw new UnsupportedOperationException();
   }

   public void setColumnMappings(int ai[])
   {
      colMappings = ai;
   }

   public void setFetchDirection(int i)
   {
      throw new UnsupportedOperationException();
   }

   public void setFetchSize(int i)
   {
      throw new UnsupportedOperationException();
   }

   protected void setInputStream(int i, PicoInputStream jdbcodbcinputstream)
   {
      if(i > 0 && i <= numberOfCols)
         boundCols[i - 1].setInputStream(jdbcodbcinputstream);
   }

   public void setPseudoCols(int i, int j, PicoPseudoCol ajdbcodbcpseudocol[])
   {
      if(DriverManager.getLogWriter() != null)
         DriverManager.println("Setting pseudo columns, first=" + i + ", last=" + j);
      firstPseudoCol = i;
      lastPseudoCol = j;
      pseudoCols = ajdbcodbcpseudocol;
   }

   public void setSQLTypeColumn(int i)
   {
      sqlTypeColumn = i;
   }

   public void setWarning(SQLWarning warn) throws SQLException {
      lastWarning = warn;
   }

   public void updateAsciiStream(int i, InputStream inputstream, int j) {
      throw new UnsupportedOperationException();
   }

   public void updateAsciiStream(String s, InputStream inputstream, int i) {
      throw new UnsupportedOperationException();
   }

   public void updateBigDecimal(int i, BigDecimal bigdecimal) {
      throw new UnsupportedOperationException();
   }

   public void updateBigDecimal(String s, BigDecimal bigdecimal) {
      throw new UnsupportedOperationException();
   }

   public void updateBinaryStream(int i, InputStream inputstream, int j) {
      throw new UnsupportedOperationException();
   }

   public void updateBinaryStream(String s, InputStream inputstream, int i) {
      throw new UnsupportedOperationException();
   }

   public void updateBoolean(int i, boolean flag) {
      throw new UnsupportedOperationException();
   }

   public void updateBoolean(String s, boolean flag) {
      throw new UnsupportedOperationException();
   }

   public void updateByte(int i, byte byte0) {
      throw new UnsupportedOperationException();
   }

   public void updateByte(String s, byte byte0) {
      throw new UnsupportedOperationException();
   }

   public void updateBytes(int i, byte abyte0[]) {
      throw new UnsupportedOperationException();
   }

   public void updateBytes(String s, byte abyte0[]) {
      throw new UnsupportedOperationException();
   }

   public void updateCharacterStream(int i, Reader reader, int j) {
      throw new UnsupportedOperationException();
   }

   public void updateCharacterStream(String s, Reader reader, int i) {
      throw new UnsupportedOperationException();
   }

   public void updateDate(int i, java.sql.Date date) {
      throw new UnsupportedOperationException();
   }

   public void updateDate(String s, java.sql.Date date) {
      throw new UnsupportedOperationException();
   }

   public void updateDouble(int i, double d) {
      throw new UnsupportedOperationException();
   }

   public void updateDouble(String s, double d) {
      throw new UnsupportedOperationException();
   }

   public void updateFloat(int i, float f) {
      throw new UnsupportedOperationException();
   }

   public void updateFloat(String s, float f) {
      throw new UnsupportedOperationException();
   }

   public void updateInt(int i, int j) {
      throw new UnsupportedOperationException();
   }

   public void updateInt(String s, int i) {
      throw new UnsupportedOperationException();
   }

   public void updateLong(int i, long l) {
      throw new UnsupportedOperationException();
   }

   public void updateLong(String s, long l) {
      throw new UnsupportedOperationException();
   }

   public void updateNull(int i) {
      throw new UnsupportedOperationException();
   }

   public void updateNull(String s) {
      throw new UnsupportedOperationException();
   }

   public void updateObject(int i, Object obj) {
      throw new UnsupportedOperationException();
   }

   public void updateObject(int i, Object obj, int j) {
      throw new UnsupportedOperationException();
   }

   public void updateObject(String s, Object obj) {
      throw new UnsupportedOperationException();
   }

   public void updateObject(String s, Object obj, int i) {
      throw new UnsupportedOperationException();
   }

   public void updateRow() {
      throw new UnsupportedOperationException();
   }

   public void updateShort(int i, short word0) {
      throw new UnsupportedOperationException();
   }

   public void updateShort(String s, short word0) {
      throw new UnsupportedOperationException();
   }

   public void updateString(int i, String s) {
      throw new UnsupportedOperationException();
   }

   public void updateString(String s, String s1) {
      throw new UnsupportedOperationException();
   }

   public void updateTime(int i, Time time) {
      throw new UnsupportedOperationException();
   }

   public void updateTime(String s, Time time) {
      throw new UnsupportedOperationException();
   }

   public void updateTimestamp(int i, Timestamp timestamp) {
      throw new UnsupportedOperationException();
   }

   public void updateTimestamp(String s, Timestamp timestamp) {
      throw new UnsupportedOperationException();
   }

   public boolean wasNull() throws SQLException {
      return lastColumnNull;
   }
}