OBJETS JDBC

//Classe Database

import java.sql.*;
import java.io.*;
import java.util.*;
import javax.swing.JOptionPane;

public class Database {
  private
    Connection cnt;
    DataSet results;
    ResultSetMetaData rsmd;
    DatabaseMetaData dma;
    String[] types;
    String productName;
    String productVersion;

  public Database(String driver) {
    try{
      types = new String[1];
      types[0] = "TABLE";
      Class.forName(driver);
    }
    catch (Exception ex){
      JOptionPane.showMessageDialog(null, "Erreur lors du chargement du driver :"+ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
    }
  }

  public void open(String url, String username, String password) {
    try{
      cnt = DriverManager.getConnection(url, username, password);
      dma = cnt.getMetaData();
      productName = dma.getDatabaseProductName();
      productVersion = dma.getDatabaseProductVersion();
      results = new DataSet(dma.getCatalogs());
      String s[] = null;
      while(results.hasMoreElements()) {
        s = results.nextElement();
      }
    }
    catch (SQLException ex){
      JOptionPane.showMessageDialog(null, "Echec d'ouverture :"+ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
    }
  }

  public void close(){
    try{
      cnt.close();
    }
    catch (SQLException ex){
      JOptionPane.showMessageDialog(null, "Echec lors de la fermeture :"+ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
    }
  }

  public String[] getTableNames() {
    String[] tbnames = null;
    Vector tname = new Vector();

    try{
      results = new DataSet(dma.getTables(null, null, "%", types));
      while (results.hasMoreElements())
        tname.addElement(results.getColumnValue("TABLE_NAME"));
    }
    catch (SQLException ex){
      JOptionPane.showMessageDialog(null, ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
    }
    tbnames = new String[tname.size()];
    for(int i=0;i<tname.size();i++)
      tbnames[i] = (String)tname.elementAt(i);
    return tbnames;
  }

  public String[] getTableMetaData() {
    results = null;

    try{
      results = new DataSet(dma.getTables(null, null, "%", types));
    }
    catch (SQLException ex){
      JOptionPane.showMessageDialog(null, ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
    }
    return results.getMetaData();
  }

  public String[] getColumnMetaData(String tablename) {
    results = null;

    try{
      results = new DataSet(dma.getColumns(null, null, tablename, null));
    }
    catch (SQLException ex){
      JOptionPane.showMessageDialog(null, ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
    }
    return results.getMetaData();
  }

  public String[] getColumnNames(String table) {
    String[] tbnames = null;
    Vector tname = new Vector();

    try{
      results = new DataSet(dma.getTables(null, null, table, null));
      while (results.hasMoreElements())
        tname.addElement(results.getColumnValue("COLUMN_NAME"));
    }
    catch (SQLException ex){
      JOptionPane.showMessageDialog(null, ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
    }
    tbnames = new String[tname.size()];
    for(int i=0;i<tname.size();i++)
      tbnames[i] = (String)tname.elementAt(i);
    return tbnames;
  }

  public void getColumnValue(String table, String columnName) {
    try{
      if (table.length()>0)
        results = executeQuery("Select "+columnName+" from "+table+" order by "+columnName);
    }
    catch (Exception ex){
      JOptionPane.showMessageDialog(null, "Erreur sur la valeur de la colonne "+columnName+ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
    }
  }

  public String getNextValue(String columnName) {
    String res = "";
    try{
      if (results.hasMoreElements())
        res = results.getColumnValue(columnName);
    }
    catch (Exception ex){
      JOptionPane.showMessageDialog(null, "Erreur sur la valeur suivante "+columnName+ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
    }
    return res;
  }

  public DataSet executeQuery(String sql){
    results = null;
    try{
      Statement stmt = cnt.createStatement();
      results = new DataSet(stmt.executeQuery(sql));
    }
    catch (SQLException ex){
      JOptionPane.showMessageDialog(null, ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
    }
    return results;
  }

  public void executeUpdate(String sql){
    try{
      Statement stmt = cnt.createStatement();
      stmt.executeUpdate(sql);
    }
    catch (SQLException ex){
      JOptionPane.showMessageDialog(null, ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
    }
  }

  public String getProductName(){
    return productName;
  }

  public String getProductVersion(){
    return productVersion;
  }
}

//Classe DataSet

import java.sql.*;
import javax.swing.JOptionPane;

public class DataSet {
  ResultSet results;
  ResultSetMetaData rsmd;
  int columnCount;
  String[] columnNames;

  public DataSet(ResultSet results){
    try {
      this.results = results;
      rsmd = results.getMetaData();
      columnCount = rsmd.getColumnCount();
    }
    catch (SQLException ex){
      JOptionPane.showMessageDialog(null, ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
    }
  }

  public boolean hasMoreElements() {
    try{
      return results.next();
    }
    catch (SQLException ex){
      JOptionPane.showMessageDialog(null, ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
      return false;
    }
  }

  public String[] getMetaData() {
    String[] s;
    s = new String[columnCount+1];
    try{
      results.next();
      for (int i=1; i<=columnCount; i++){
        s[i] = results.getString(i);
      }
    }
    catch (SQLException ex){
      JOptionPane.showMessageDialog(null, ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
    }
    return s;
  }

  public String[] nextElement() {
    String[] line;
    line = new String[columnCount+1];
    try{
      for (int i = 1; i <= columnCount; i++){
        line[i] = results.getString(i);
      }
    }
    catch (SQLException ex){
      JOptionPane.showMessageDialog(null, ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
    }
    return line;
  }

  public String getColumnValue(String columnName) {
    try{
      return results.getString(columnName);
    }
    catch (SQLException ex){
      JOptionPane.showMessageDialog(null, ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
      return "";
    }
  }

  public int getColumnCount(){
    return columnCount;
  }

  public String getColumnName(int i) {
    try{
      return rsmd.getColumnName(i);
    }
    catch (SQLException ex){
      JOptionPane.showMessageDialog(null, ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
      return "";
    }
  }

  public String getColumnLabel(int i) throws SQLException {
    try{
      return rsmd.getColumnLabel(i);
    }
    catch (SQLException ex){
      JOptionPane.showMessageDialog(null, ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
      return "";
    }
  }

  public int getColumnDisplaySize(int i) throws SQLException {
    try{
      return rsmd.getColumnDisplaySize(i);
    }
    catch (SQLException ex){
      JOptionPane.showMessageDialog(null, ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
      return 0;
    }
  }

  public int getColumnType(int i) throws SQLException{
    try{
      return rsmd.getColumnType(i);
    }
    catch (SQLException ex){
      JOptionPane.showMessageDialog(null, ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
      return 0;
    }
  }

  public String getColumnTypeName(int i) throws SQLException{
    try{
      return rsmd.getColumnTypeName(i);
    }
    catch (SQLException ex){
      JOptionPane.showMessageDialog(null, ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
      return "";
    }
  }

  public String getCatalogName(int i) throws SQLException{
    try{
      return rsmd.getCatalogName(i);
    }
    catch (SQLException ex){
      JOptionPane.showMessageDialog(null, ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
      return "";
    }
  }

  public boolean isAutoIncrement(int i) throws SQLException{
    try{
      return rsmd.isAutoIncrement(i);
    }
    catch (SQLException ex){
      JOptionPane.showMessageDialog(null, ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
      return false;
    }
  }

  public String getSchemaName(int i) throws SQLException{
    try{
      return rsmd.getSchemaName(i);
    }
    catch (SQLException ex){
      JOptionPane.showMessageDialog(null, ex.getMessage(), "Exception SQL", JOptionPane.ERROR_MESSAGE);
      return "";
    }
  }
}