import java.sql.*;

/**
   SimpleInsert
   @author Benedikt Großer, Holger Arndt
   @version 03.06.2003
*/
public class SimpleInsert
{ 
  public static void main(String[] args)
  {
    // Diese Einträge werden zum
    // Verbindungsaufbau benoetigt.
    final String hostname = "localhost";
    final String port = "3306";
    final String dbname = "JavaVorl";
    final String user = System.getProperty("user.name");
    final String password = "";
    
    Connection conn = null; 
    try
      {
	System.out.println("* Treiber laden");
	Class.forName("com.mysql.jdbc.Driver").newInstance();
      }
    catch (ClassNotFoundException cnfe)
      {
	System.err.println("Konnte Treiber nicht laden.");
	cnfe.printStackTrace();
      }
    catch (InstantiationException ie)
      {
	System.err.println("Konnte Treiber nicht laden.");
	ie.printStackTrace();
      }
    catch (IllegalAccessException iae)
      {
	System.err.println("Konnte Treiber nicht laden.");
	iae.printStackTrace();
      }

    try
      {
	System.out.println("* Verbindung aufbauen");
	String url = "jdbc:mysql://" + hostname + ":" + port + "/" + dbname;
	conn = DriverManager.getConnection(url, user, password);
	
	System.out.println("* Statement beginnen"); 
	Statement stmt = conn.createStatement(); 
	
	System.out.println("* Einfuegen"); 
	String sqlCommand = 
	  "INSERT INTO personal " + 
	  "VALUES('Heizer', 666, 'Karben', 'Kfz', 'F&E', 2, 34000);"; 
	stmt.executeUpdate(sqlCommand); 
	
	System.out.println("* Statement beenden"); 
	stmt.close();
	
	System.out.println("* Statement beginnen");
	stmt = conn.createStatement();
	
	System.out.println("* Abfrage beginnen");
	sqlCommand = "SELECT Name, StOrt, Gehalt FROM personal";
	ResultSet rs = stmt.executeQuery(sqlCommand);
	
	System.out.println("* Ergebnisse anzeigen"); 
	while (rs.next())
	  {
	    String name = rs.getString(1);
	    String standort = rs.getString("StOrt");
	    double gehalt = rs.getDouble(3);
	    System.out.println(name + " " + standort + " " + gehalt);
	  }
	
	System.out.println("* Statement beenden");
	stmt.close();
	
	System.out.println("* Datenbank-Verbindung beenden");
	conn.close();
      } 
    catch (SQLException sqle)
      {
	System.out.println("SQLException: " + sqle.getMessage());
	System.out.println("SQLState: " + sqle.getSQLState());
	System.out.println("VendorError: " + sqle.getErrorCode());
	sqle.printStackTrace();
      }
  } // ende: public static void main() 
} // ende: public class SimpleQuery