import  java.sql.ResultSet;
 import  java.sql.ResultSetMetaData;
 import  java.sql.SQLException;
 import  java.sql.SQLWarning;
 import  java.util.Vector;

 import  javax.swing.JTextArea;
 import  javax.swing.table.DefaultTableModel;

/**
 * Этот класс предназначен для реализации модели таблицы
 * 
 * @author admin
 * 
 */
 public   class  DefaultReplyTableModel  extends  DefaultTableModel {
	 private  ResultSetMetaData rsmd =  null ;

	 private  ResultSet resultSet =  null ;

	Vector data =  this .getDataVector();

	 private  Vector headers =  null ;


	/*
	 * (non-Javadoc)
	 * 
	 * @see javax.swing.table.DefaultTableModel#getColumnName(int)
	 */

	@Override
	 public  String getColumnName( int  column) {
		 return   super .getColumnName(column);
	}

	/**
	 * этот метод самостоятельно создает ResultSet согласно query и данному
	 * подключению. ResultSet будет иметь свойства:
	 * ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE
	 * 
	 * @param connection
	 * @param query
	 */
	 public   void  performResultSet(java.sql.Connection connection, String query) {
		 boolean  stay = false;
		java.sql.Statement statement =  null ;

		 try  {
			statement = connection.createStatement(
					ResultSet.TYPE_SCROLL_INSENSITIVE,
					ResultSet.CONCUR_UPDATABLE);
			stay = statement.execute(query.toString());
			
			 if  (stay) {
				performResultSet(statement.getResultSet());
			}  else  {
				createDatabaseReplay(statement.getUpdateCount());
			}

		}  catch  (SQLException e) {
			performSQLException(connection, e);
		}
	}

	/**
	 * этот метод вызывается если результат выполнения sql-запроса есть
	 * resultSet таблица
	 * 
	 * @param resultSet
	 */
	 public   void  performResultSet(ResultSet resultSet) {
		 this .resultSet=resultSet;
		 int  columnCountOfResultSet =  0 ;
		data.clear();
		 try  {
			rsmd =  this .resultSet.getMetaData();
			columnCountOfResultSet = rsmd.getColumnCount();

			// создадим заголовки
			headers =  new  Vector(columnCountOfResultSet);
			 for  ( int  columnInd =  0 ; columnInd < columnCountOfResultSet; columnInd++)
				headers.add(rsmd.getColumnName(columnInd +  1 ));

			 if  (getRowCount() ==  0 ) {

				 int  ind =  1 ;

				Vector row =  null ;
				Object obj =  null ;
				 while  ( this .resultSet.next()) {
					row =  new  Vector();
					 for  ( int  i =  1 ; i <= columnCountOfResultSet; i++) {
						obj =  this .resultSet.getObject(ind++);
						row.add(obj);
					}
					ind =  1 ;
					data.add(row);
					row =  null ;
				}
			}

			setDataVector(data,  this .headers);
			 this .fireTableDataChanged();
		}  catch  (SQLException e) {
			// pearent.errorTextArea.append(e.getMessage());
			// e.printStackTrace();
		}  catch  (Exception e) {
			e.printStackTrace();
		}
	}

	 public   void  createDatabaseReplay( int  numUpdates) {
		headers =  new  Vector( 1 );
		headers.add("Replay");

		data.clear();
		Vector row =  new  Vector( 1 );
		row.add("Ok. " + numUpdates + " rows affected.");
		data.add(row);
		 this .setDataVector(data, headers);
		 this .fireTableDataChanged();
	}

	/**
	 * этот метод обрабатывает ошибку и отражает результат работы в таблице
	 * (через модель)
	 * 
	 * @param exp
	 */
	 public   void  performSQLException(java.sql.Connection connection,
			SQLException exp) {
		SQLWarning sqlWarning;
		SQLException sqlExp = exp;
		String warning =  null ;
		Vector row =  null ;

		headers =  new  Vector( 1 );
		headers.add("Error by query execution");
		data.clear();
		 try  {
			 for  (sqlWarning = connection.getWarnings(); sqlWarning !=  null ; sqlWarning = sqlWarning
					.getNextWarning()) {
				row =  new  Vector();
				warning = (warning ==  null  ? "" : warning) + "WARNING: "
						+ sqlWarning.getMessage() + ":"
						+ sqlWarning.getSQLState() + "\n";
				row.add(warning);
				data.add(row);
			}

			// === обработка ошибок ===
			 while  (sqlExp !=  null ) {
				row =  new  Vector();
				row.add(sqlExp.getMessage());
				data.add(row);
				sqlExp = exp.getNextException();
			}
			// === удалим старые сообщения ===
			connection.clearWarnings();
		}  catch  (SQLException e) {
			e.printStackTrace();
		}

		 this .setDataVector(data, headers);
		 this .fireTableDataChanged();
	}
	
	/**
	 * метод возвращает сформированный resultSet
	 * @return
	 */
	 public  ResultSet getResultSet(){
		 return  resultSet;
	}

	 public  Vector getHeaders() {
		 return  headers;
	}

}

JTable table= new  JTable();
table.setModel( new  DefaultReplyTableodel);