Tietokantaohjelmointi ja Java-tietokantaliittymä

 /* sisällytetään C.n tarvitsemat .h otsaketiedostot */
 #include <stdio.h>
 #include <string.h>

 /* sisällytetään palautetietoa välittävän SQL communication Area:n */
 /* määrittely */ 
 #include <sqlca.h>
 #define ID_len 20 

 /* Määritellään ns. yhteismuuttujat, joilla välitetään tietoa */
 /* SQL-operaatioihin */
 /* EXEC SQL aloittaa esikääntäjälle tarkoitetun osuuden */ 

 EXEC SQL BEGIN DECLARE SECTION; 
    varchar tunnus[ID_len], salasana[ID_len];
    varchar hakuehto[40];
 EXEC SQL END DECLARE SECTION;


 /* muuttujat, jonne data siirretään kannasta */

 struct {
   varchar nimi[40];
   varchar havainto [20];
 } opiskelijarivi;

 /* Indikaattorimuuttujat, joilla tarkkaillaan vastauskenttien tilaa */
 /* indikaattorimuuttujan arvo poikkeaa nollasta erilaisissa sarake- */
 /* kohtaisissa virhe- tai poikkeustilanteissa */  

 struct {short nimi_ind, havainto_ind; } opiskelija_ind;

 /* opiskelijalaskuri */ 
 int opiskelija_lkm=0;

 /* Määritellään tarpeellisia apufunktioita */ 
 void kysy_tunnus();
 void kysy_hakuehto(); 
 void sql_error(); 

 main() {
   /* Rekisteröidään sql_error() funktio virhekäsittelijäksi. */ 
   EXEC SQL WHENEVER SQLERROR DO sql_error("Oracle error \n");

   /* kysytään käyttäjätunnus ja salasana */ 
   kysy_tunnus(&tunnus,&salasana);

   /* Kytkeydytään tietokantaan */
   /* SQL lauseessa kaksoispiste nimen alussa kertoo, */
   /* että kyseessä on viittaus ohjelmamuuttujan arvoon */
   EXEC SQL CONNECT :tunnus IDENTIFIED BY :salasana; 

   /* Määritellään kysely */
   /* hakuehto-muuttujan arvo evaluoidaan vasta kun kysely suoritetaan */ 
   EXEC SQL DECLARE opiskelija_haku CURSOR FOR
     SELECT rpad(substr(sukunimi||' '||etunimet,1,40),40) nimi,
         to_char(viim_havainto_pvm,'DD.MM.YYYY') 
     FROM OPISKELIJA
     WHERE upper(SUKUNIMI) LIKE upper(:hakuehto)
     ORDER BY nimi;

  /* kysytään käyttäjältä hakuehto */   
  kysy_hakuehto(&hakuehto);

  /* suoritetaan kysely */
  /* hakuehto-muuttujan arvo tässä kohdassa määrää haun kohteen */
  EXEC SQL OPEN opiskelija_haku;

  /* määritellään, että poistutaan silmukasta */
  /* kun ei enää ole rivejä jäljellä */ 
  EXEC SQL WHENEVER NOT FOUND DO break;

  /* vastauksen läpikäyntisilmukka */ 
  for (;;) {
     /* seuraavan rivin tiedot ohjelman työalueelle */
     EXEC SQL FETCH opiskelija_haku 
        INTO :opiskelijarivi INDICATOR :opiskelija_ind;

     /* tulostetaan opiskelijan tiedot */
     /* varchar tietotyypissä erillisenä kenttänä arvotaulukko */
     printf(" %s viimeisin kontakti: %s \n", opiskelijarivi.nimi.arr,
        opiskelijarivi.havainto.arr);
     opiskelija_lkm++;
  } 
  printf("\nOpiskelijoita yhteensä %d",opiskelija_lkm);      

  /* päätetään kyselyn käsittely, vapautetaan resurssit */
  ECEC SQL CLOSE opiskelija_haku;

  /* tulostetaan haettujen opiskelijoiden lukumäärä */
  printf("\nHakuehdon täyttäviä opiskelijoita: %d",opiskelija_lkm);

  /* varmuuden vuoksi vaikka tässä onkin vain kysely */
  EXEC SQL COMMIT WORK RELEASE; 

  exit(0); 
}


void kysy_tunnus(varchar *username, varchar *userpasswd) { 
/* kysytään käyttäjältä käyttäjätunnus ja salasana */
/* ohjelmakoodi puuttuu */
} 

void kysy_hakuehto(varchar *ehto) {
/* kysytään sukunimeen perustuva hakuehto */
  char hehto[40];
  printf("\nAnna sukunimi: ");      
  scanf("%s",&hehto);
  strcpy((char*) (ehto->arr), hehto);
  ehto->len = strlen((char*)(ehto.arr));
}

void sql_error(char *msg) {
   /* virheilmoitus */ 
   char err_msg[512]; 
   int buff_len, msg_len; 
   EXEC SQL WHENEVER SQLERROR CONTINUE;
   printf("\n%s\n",msg); 
   /* sqlglm() antaa virheilmoitukseen liittyvän tekstin */ 
   buff_len = sizeof(err_msg); 
   sqlglm(err_msg,&buff_len, &msg_len); 
   printf("%.*s\n", msg_len,err_msg);

   /* Rollback jos on tehty muutoksia */ 
   EXEC SQL ROLLBACK RELEASE; 
   exit(1); 
}
 

 // Parametroitua kyselyä käyttävä versio
 // Otetaan mukaan tarvittavia kirjastoja 
 // CLASSPATH:ssa täytyy olla polku ajuriin

 #import java.sql.*;
 #import java.io.*;

 public class Esimerkki {

   public static void main(String args[]) throws Exception {
     // tietokantayhteyden määrittelyä - oracle thin ajurilla yhteys
     // koneessa bodbacka.cs.helsinki.fi toimivaan test kantaan
     String url= "jdbc:oracle:thin:@bodbacka.helsinki.fi:1521:test";
     String ajuri= "oracle.jdbc.OracleDriver";

     // kysely - tässä käytetään parametroitua kyselyä 
     // kysymysmerkki osoittaa parametrin
     String opiskelija_haku =
       "SELECT rpad(substr(sukunimi||\' \'||etunimet,1,40),40) nimi,"+
       "    to_char(viim_havainto_pvm,\'DD.MM.YYYY\') vhp "+ 
       "FROM OPISKELIJA "+
       "WHERE upper(SUKUNIMI) LIKE upper(?) "
       "ORDER BY nimi";

     int opiskelija_lkm=0;        // opiskelijoiden lukumäärä
     Connection con=null;         // tietokantayhteysmuuttuja
     PreparedStatement stm= null; // kyselyn suoritusympäristö
     ResultSet rs= null;          // kyselyn vastausjoukko

     // Rekisteröidään ajuri 
     // Ajurit osaavat rekisteröityä itse kun ne ladataan,
     // joten tässä ei tarvita DriverManagerin registerDriver -kutsua 

     try {
        Class.forName(ajuri);
     } catch (ClassNotFoundException) {
        System.out.println("Ajurin lataus ei onnistu");
        return;
     }  

     // kysytään käyttäjätunnus ja salasana  
     BufferedReader stdin =
        new BufferedReader(new InputStreamReader(System.in));
     System.out.print("Käyttäjätunnus: ");
     String tunnus= stdin.readLine();
     System.out.print("Salasana: ");   
     String salasana= stdin.readLine();

     // Luodaan tietokantayhteys
     try {  
       con=DriverManager.getConnection(url,tunnus,salasana);
     } catch (SQLExecption ss) {
        System.out.println("Tietokantayhteyden avaus ei onnistu");
        return;
     } 
   
     try {
       // Luodaan suoritusympäristö ja käännetään kysely 
       stm= con.prepareStatement(opiskelija_haku);

       // kysytään käyttäjältä hakuehto   
       System.out.print("Hakuehto: ");
       String hakuehto= stdin.readLine();

       // asetetaan kyselyn parametri 
       stm.setString(1,hakuehto);

       // suoritetaan kysely 
       rs = stm.executeQuery();

       // käydään läpi vastausrivit 
       while (rs.next()) {
         // haetaan arvot get-funktioilla
         System.out.println(rs.getString("NIMI")+
                             " viimeisin kontakti "+
                             rs.getString("VHP"));
         opiskelija_lkm++;       
       }

       System.out.print("\nOpiskelijoita yhteensä: ");
       System.out.println(opiskelija_lkm);   
    } catch (SQLException e) {
      // tulostetaan tkhj:n tuottama virheilmoitus
      System.out.println("Tietokantavirhe "+ e.getMessage());
    } finally { 
      // lopuksi vapautetaan resurssit   
        try {
          if (rs!=null)
            rs.close();
          if (stm!=null) 
            stm.close();
          con.close();
        } catch (SQLException s) {}    
    }
 }
}

 // Parametroimatonta kyselyä käyttävä versio
 // Otetaan mukaan tarvittavia kirjastoja 
 // CLASSPATH:ssa täytyy olla polku ajuriin

 import java.sql.*;
 import java.io.*;

 public class Esimerkki2 {

    public static void main(String args[]) throws Exception {
     // tietokantayhteyden määrittelyä - oracle thin ajurilla yhteys
     // koneessa kontti.helsinki.fi toimivaan tktb kantaan
     String url= "jdbc:oracle:thin:@bodbacka.cs.helsinki.fi:1521:test";
     String ajuri= "oracle.jdbc.OracleDriver";

     // kysely - tässä käytetään parametroimatonta kyselyä 
     String opiskelija_haku =
       "SELECT rpad(substr(sukunimi||\' \'||etunimet,1,40),40) nimi,"+
       "    to_char(viim_havainto_pvm,\'DD.MM.YYYY\') vhp "+ 
       "FROM OPISKELIJA "+
       "WHERE upper(SUKUNIMI) LIKE upper(";

     int opiskelija_lkm=0;        // opiskelijoiden lukumäärä
     Connection con=null;         // tietokantayhteysmuuttuja

     Statement stm= null;         // kyselyn suoritusympäristö
     ResultSet rs= null;          // kyselyn vastausjoukko

     // Rekisteröidään ajuri 
     // Ajurit osaavat rekisteröityä itse kun ne ladataan,
     // joten tässä ei tarvita DriverManagerin registerDriver -kutsua 

     try {
        Class.forName(ajuri);
     } catch (ClassNotFoundException) {
        System.out.println("Ajurin lataus ei onnistu");
        return;
     }  

     /* kysytään käyttäjätunnus ja salasana */ 
     BufferedReader stdin =
        new BufferedReader(new InputStreamReader(System.in));
     System.out.print("Käyttäjätunnus: ");
     String tunnus= stdin.readLine();
     System.out.print("Salasana: ");   
     String salasana= stdin.readLine();

     // Luodaan tietokantayhteys
     try {   
       con=DriverManager.getConnection(url,tunnus,salasana);
     } catch (SQLExecption ss) {
        System.out.println("Tietokantayhteyden avaus ei onnistu");
        return;
     } 

     try {  
       // Luodaan suoritusympäristö ja käännetään kysely 
       stm= con.createStatement();

       // kysytään käyttäjältä hakuehto   
       System.out.print("Hakuehto: ");
       String hakuehto= stdin.readLine();

       // rakennetaan kysely lisäämällä muuttujan hakuehto
       // arvo yksinkertaisissa lainausmerkeissä alkuosan perään
       // ja suoritetaan rakennettu kysely 

       rs = stm.executeQuery(opiskelija_haku + "\'" +
                             hakuehto+"\') ORDER BY nimi");

       // käydään läpi vastausrivit 
       while (rs.next()) {
         // haetaan arvot get-funktioilla
         System.out.println(rs.getString("NIMI")+
                             " viimeisin kontakti "+
                             rs.getString("VHP"));
         opiskelija_lkm++;       
       }
       System.out.print("\nOpiskelijoita yhteensä: ");
       System.out.println(opiskelija_lkm);   
    } catch (SQLException e) {
      // tulostetaan tkhj:n tuottama virheilmoitus
      System.out.println("Tietokantavirhe "+ e.getMessage());
    } finally { 
      // lopuksi vapautetaan resurssit   
        try {
          if (rs!=null)
            rs.close();
          if (stm!=null) 
            stm.close();
          con.close();
        } catch (SQLException s) {}
    }
  }
}

 // Ylläpito-ohjelma
 // Otetaan mukaan tarvittavia kirjastoja 
 // CLASSPATH:ssa täytyy olla polku ajuriin

 import java.sql.*;
 import java.io.*;

 public class YllapitoEsimerkki {

   public static void main(String args[]) throws Exception {
     // tietokantayhteyden määrittelyä - oracle thin ajurilla yhteys
     // koneessa kontti.helsinki.fi toimivaan tktb kantaan
     String url= "jdbc:oracle:thin:@bodbacka.cs.helsinki.fi:1521:test";
     String ajuri= "oracle.jdbc.OracleDriver";

     // muutoksen kohteet hakeva kysely
     String opettaja_haku =
       "SELECT opetunnus, sukunimi||\' \'||etunimet NIMI "+ 
       "FROM OPETTAJA "+
       "WHERE TYOPUHELIN IS NULL " +
       "ORDER BY NIMI";

     // parametroitu muutosoperaatio
     String muutos =   
       "UPDATE OPETTAJA "+
       "SET TYOPUHELIN = ? "+
       "WHERE OPETUNNUS = ?";

     Connection con=null;         // tietokantayhteysmuuttuja
     Statement stm= null;         // kyselyn suoritusympäristö
     PreparedStatement pstm = null;   //ylläpidon suoritusympäristö;
     ResultSet rs= null;          // kyselyn vastausjoukko
     String tunnus= "MIKKI";
     String salasana= "HIIRI";

     // Rekisteröidään ajuri 
     // Ajurit osaavat rekisteröityä itse kun ne ladataan,
     // joten tässä ei tarvita DriverManagerin registerDriver -kutsua 
     try {
        Class.forName(ajuri);
     } catch (ClassNotFoundException) {
        System.out.println("Ajurin lataus ei onnistu");
        return;
     }  

     BufferedReader stdin =
        new BufferedReader(new InputStreamReader(System.in));

     // Luodaan tietokantayhteys 
     try {
       con=DriverManager.getConnection(url,tunnus,salasana);
     }
     catch (SQLException s1) {
       System.out.println("Tietokantaan ei saada yhteyttä!");
       return;
     }

     try {  
       // Luodaan kyselyn suoritusympäristö
       stm= con.createStatement();

       // käännetään ylläpito-operaatio
       pstm= con.prepareStatement(muutos);

       // Suoritetaan kysely 
       rs = stm.executeQuery(opettaja_haku);

       // tulostetaan otsake
       System.out.println("ANNA TYÖPUHELINNUMEROT");
       SYSTEM.out.println("======================");
       String puhno= null;

       // käydään läpi vastausrivit 
       while (rs.next()) {
         // kysytään numeroa nimellä
         System.out.print(rs.getString("NIMI")+": ");
         puhno= stdin.readLine();
         if (puhno!=null) {
            // asetetaan ylläpito-operaation parametriarvot
            pstm.setString(1,puhno);
            pstm.setString(2,getString("OPETUNNUS"));
            // suoritetaan ylläpito-operaatio
            pstm.executeUpdate();
            // vahvistetaan kukin muutos omana tapahtumanaan 
            con.commit();
         }          
       }   
     } catch (SQLException e) {
        // tulostetaan tkhj:n tuottama virheilmoitus
        System.out.println("Tietokantavirhe "+ e.getMessage());
     } finally { 
        // lopuksi vapautetaan resurssit   
        try {
           if (rs!=null) 
              rs.close();
           if (stm!=null) 
              stm.close(); 
           if (pstm!=null) 
              pstm.close();
           con.close();
        } catch (SQLException s) {}
    }
 }