/** * @(#)Tietokanta.java * * Tietokanta application * * @author * @version 1.00 2009/11/19 */ import java.sql.*; class Muistio { private String ajuri; private String dsn; public Muistio ( String ajuri, String dsn ) { this.ajuri = ajuri; this.dsn = dsn; } public String lue ( String sql_lause ) { Connection yhteys; Statement lause; ResultSet tulos; String nimi, osoite, numero, mj = ""; try { Class.forName( ajuri ).newInstance(); } catch ( Exception e ) { System.out.println( "Ajuri ei toimi." ); } try { yhteys = DriverManager.getConnection( dsn ); lause = yhteys.createStatement(); tulos = lause.executeQuery( sql_lause ); while ( tulos.next() ) { nimi = tulos.getString(1); osoite = tulos.getString(2); numero = tulos.getString(3); mj += nimi + "\t" + osoite + "\t" + numero + "\n"; } lause.close(); yhteys.close(); } catch ( SQLException sql_e ) { System.err.println( sql_e.getMessage() ); } return mj; } public void kirjoita ( String sql_lause ) { Connection yhteys; Statement lause; ResultSet tulos; try { Class.forName( ajuri ).newInstance(); } catch ( Exception e ) { System.out.println( "Ajuri ei toimi." ); } try { yhteys = DriverManager.getConnection( dsn ); lause = yhteys.createStatement(); tulos = lause.executeQuery( sql_lause ); lause.close(); yhteys.close(); } catch ( SQLException sql_e ) { System.err.println( sql_e.getMessage() ); } } } public class Tietokanta { public static void main(String[] args) { Muistio muistio = new Muistio("sun.jdbc.odbc.JdbcOdbcDriver", "jdbc:odbc:ihmiset"); String tiedot=""; muistio.kirjoita( "INSERT INTO ihmiset ( nimi, osoite, numero ) VALUES ( 'Hessu', 'Ankkalinna', '987698769' ) "); tiedot = muistio.lue("SELECT * FROM ihmiset.txt ihmiset"); System.out.println(tiedot); } } /* ihmiset.txt nimi|osoite|numero Mikki|Ankkalinna|123456 Tintti|Bryssel|9876754 schema.ini [ihmiset.txt] ColNameHeader=True Format=Delimited(|) MaxScanRows=25 CharacterSet=ANSI Col1=NIMI Char Width 255 Col2=OSOITE Char Width 255 Col3=NUMERO Char Width 255 */