Logo Search packages:      
Sourcecode: henplus version File versions  Download package

int henplus::commands::DescribeCommand::execute ( SQLSession  session,
String  cmd,
String  param 
) [inline]

execute the command given.

Implements henplus::Command.

Definition at line 71 of file DescribeCommand.java.

References henplus::view::TableRenderer::addRow(), henplus::view::TableRenderer::closeTable(), henplus::commands::ListUserObjectsCommand::correctTableName(), henplus::Command::EXEC_FAILED, henplus::SQLSession::getConnection(), henplus::view::ColumnMetaData::resetWidth(), henplus::view::ColumnMetaData::setDisplay(), henplus::Command::SUCCESS, and henplus::Command::SYNTAX_ERROR.

                                                                     {
      final StringTokenizer st = new StringTokenizer(param);
      final int argc = st.countTokens();
      if (argc != 1) {
          return SYNTAX_ERROR;
      }
      boolean correctName = true;
      String tabName = (String) st.nextElement();
      if (tabName.startsWith("\"")) {
          tabName = stripQuotes(tabName);
          correctName = false;
      }

        // separate schama and table.
        String schema = null;
        int schemaDelim = tabName.indexOf('.');
        if (schemaDelim > 0) {
            schema = tabName.substring(0, schemaDelim);
            tabName = tabName.substring(schemaDelim+1);
        }
        
        // FIXME: provide correct name as well for schema!
      if (correctName) {
          String alternative = tableCompleter.correctTableName(tabName);
          if (alternative != null && !alternative.equals(tabName)) {
            tabName = alternative;
            HenPlus.out().println("describing table: '" + tabName 
                           + "' (corrected name)");
          }
      }
        
      ResultSet rset = null;
        Set doubleCheck = new HashSet();
      try {
            interrupted = false;
            SigIntHandler.getInstance().pushInterruptable(this);
          boolean anyLeftArrow  = false;
          boolean anyRightArrow = false;
            long startTime = System.currentTimeMillis();
            String catalog = session.getConnection().getCatalog();

            if (interrupted) return SUCCESS;

          DatabaseMetaData meta = session.getConnection().getMetaData();
          for (int i=0; i < DESC_META.length; ++i) {
            DESC_META[i].resetWidth();
          }

          /*
           * get primary keys.
           */
            if (interrupted) return SUCCESS;
          Map pks = new HashMap();
          rset = meta.getPrimaryKeys(null, schema, tabName);
          if (rset != null) while (!interrupted && rset.next()) {
            String col = rset.getString(4);
            int pkseq  = rset.getInt(5);
            String pkname = rset.getString(6);
            String desc = (pkname != null) ? pkname : "*";
            if (pkseq > 1) {
            desc = StringAppender.getInstance().append( desc ).append( "{" ).append( pkseq ).append( "}" ).toString();
                // desc += "{" + pkseq + "}";
            }
            pks.put(col, desc);
          }
          rset.close();

          /*
           * get referenced primary keys.
           */
            if (interrupted) return SUCCESS;
          rset = meta.getExportedKeys(null, schema, tabName);
          if (rset != null) while (!interrupted && rset.next()) {
            String col = rset.getString(4);
            String fktable = rset.getString(7);
            String fkcolumn  = rset.getString(8);
            fktable = StringAppender.getInstance().append( fktable ).append( "(" ).append( fkcolumn ).append( ")" ).toString();
            String desc = (String) pks.get(col);
            desc = (desc == null) 
                ? StringAppender.start(" <- ").append(fktable).toString()
                : StringAppender.start(desc).append("\n <- ").append(fktable).toString();
            anyLeftArrow = true;
            pks.put(col, desc);
          }
          rset.close();

          /*
           * get foreign keys.
           */
            if (interrupted) return SUCCESS;
          Map fks = new HashMap();
        
        // some jdbc version 2 drivers (connector/j) have problems with foreign keys...
        try {
            rset = meta.getImportedKeys(null, schema, tabName);
        } catch ( NoSuchElementException e ) {
            if (verbose)
                HenPlus.msg().println("Database problem reading meta data: " + e);
        }
          if (rset != null) {
            while (!interrupted && rset.next()) {
                String table = rset.getString(3);
                String pkcolumn  = rset.getString(4);
                table = table + "(" + pkcolumn + ")";
                String col = rset.getString(8);
                String fkname = rset.getString(12);
                String desc = (fkname != null) ? StringAppender.start(fkname).append("\n -> ").toString() : " -> ";
                desc += table;
                anyRightArrow = true;
                fks.put(col, desc);
            }
          }
          rset.close();

        if (catalog != null) HenPlus.msg().println("catalog: " + catalog);
          if (anyLeftArrow)  HenPlus.msg().println(" '<-' : referenced by");
          if (anyRightArrow) HenPlus.msg().println(" '->' : referencing");

          /*
           * if all columns belong to the same table name, then don't
           * report it. A different table name may only occur in rare
           * circumstance like object oriented databases.
           */
          boolean allSameTableName = true;

          /*
           * build up actual describe table.
           */
            if (interrupted) return SUCCESS;

          rset = meta.getColumns(catalog, schema, tabName, null);
          List rows = new ArrayList();
        int colNum = 0;
          if (rset != null) {
            while (!interrupted && rset.next()) {
                Column[] row = new Column[8];
                row[0] = new Column( ++colNum );
                String thisTabName = rset.getString(3);
                row[1] = new Column( thisTabName );
                allSameTableName &= tabName.equals(thisTabName);
                String colname = rset.getString(4);
                if (doubleCheck.contains(colname)) {
                    continue;
                }
                doubleCheck.add(colname);
                row[2] = new Column( colname );
                String type = rset.getString(6);
                int colSize = rset.getInt(7);
                if (colSize > 0)
                    type = StringAppender.start(type).append("(").append(colSize).append(")").toString();
                
                row[3] = new Column( type );
                String defaultVal = rset.getString(13);
                row[4] = new Column( rset.getString(18) );
                // oracle appends newline to default values for some reason.
                row[5] = new Column( ((defaultVal != null) 
                                ? defaultVal.trim() 
                                : null) );
                String pkdesc = (String) pks.get(colname);
                row[6] = new Column( (pkdesc != null) ? pkdesc : "");
                String fkdesc = (String) fks.get(colname);
                row[7] = new Column( (fkdesc != null) ? fkdesc : "");
                rows.add(row);
           }
          }
          rset.close();

          /*
           * we render the table now, since we only know know, whether we
           * will show the first column or not.
           */
          DESC_META[1].setDisplay(!allSameTableName);
          TableRenderer table = new TableRenderer(DESC_META, HenPlus.out());
          Iterator it = rows.iterator();
          while (it.hasNext()) {
                table.addRow((Column[]) it.next());
            }
          table.closeTable();

            if ("describe".equals(cmd)) {
                /*
                 * no index describe
                 */
                return SUCCESS;
            }

          /*
           * index info.
           */
            if (interrupted) return SUCCESS;
          HenPlus.out().println("index information:");
          boolean anyIndex = false;
          rset = meta.getIndexInfo(null, schema, tabName, false, true);
          if (rset != null) while (!interrupted && rset.next()) {
            boolean nonUnique;
            String idxName = null;
            nonUnique = rset.getBoolean(4);
            idxName = rset.getString(6);
            if (idxName == null) continue; // statistics, otherwise.
            // output part.
            anyIndex = true;
            HenPlus.out().print("\t");
            if (!nonUnique) HenPlus.out().print("unique ");
            HenPlus.out().print("index " + idxName);
            String colName = rset.getString(9);
            // work around postgres-JDBC-driver bug:
            if (colName != null && colName.length() > 0) {
                HenPlus.out().print(" on " + colName);
            }
            HenPlus.out().println();
          }
          rset.close();
          if (!anyIndex) {
            HenPlus.out().println("\t<none>");
          }
            TimeRenderer.printTime(System.currentTimeMillis() - startTime,
                                   HenPlus.out());
            HenPlus.out().println();
      }
      catch (Exception e) {
          if (verbose)
            e.printStackTrace();
        String ex = ( e.getMessage() != null ) ? e.getMessage().trim() : e.toString();
        HenPlus.msg().println("Database problem reading meta data: " + ex);
          return EXEC_FAILED;
      }
      finally {
          if (rset != null) {
            try { rset.close(); } catch (Exception e) {}
          }
      }
      return SUCCESS;
    }


Generated by  Doxygen 1.6.0   Back to index