FAQ JDBCConsultez toutes les FAQ

1
2
3
4
java.util.Date date = new java.util.Date(); 
java.sql.Date dateSQL = new java.sql.Date(date.getTime()); 
Time time = new Time(date.getTime()); 
Timestamp time = new Timestamp(date.getTime());

Date date = Date.valueOf("2004-10-20");

CREATE TYPE TELEPHONE AS CHAR(10);

1
2
3
4
5
ResultSet resultset = ...;  
while(resultset.next()){ 
   String telephone = resultset.getString("Telephones"); 
   //... 
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
Statement statement = ... ;  
String sql = "SELECT * FROM MaTable"; 
ResultSet resultset = statement.executeQuery(sql);  
while(resultset.next()){ 
   Array array = resultset.getArray("colonneArray"); 
   //array est un simple "pointeur" 
   Object tableau = array.getArray(); 
   //tableau est tableau Java 
   String[] donneesTableau = (String[])tableau; 
   //vous devez le caster dans le type de données contenues 
   for(int i=0; i<donneesTableau.length ; i++){ 
      System.out.println(donneesTableau[i]); 
   }  
}

1
2
3
4
5
6
7
8
9
10
11
12
13
Statement statement = ... ;  
String sql = "SELECT * FROM MaTable"; 
ResultSet resultset = statement.executeQuery(sql);  
while(resultset.next()){ 
   Array array = resultset.getArray("colonneArray"); 
   //array est un simple "pointeur" 
   ResultSet tableau = array.getResultSet(); 
   //tableau est un ResultSet contenant les données de l'Array 
   while(tableau.next()){ 
      System.out.println(tableau.getString(1)); 
      //le ResultSet n'a qu'une colonne 
   } 
}

1
2
3
4
Array array = resultset.getArray("colonneArray"); 
int index = 3;  
int longueur = 4;  
ResultSet tableau = array.getResultSet(index, longueur);

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
public static void insererImage(String nom, String chemin) { 
   File file = new File(chemin); 
   try{ 
      //lien vers la base de données 
      Connection connection = DriverManager.getConnection("url","user","password"); 
  
      //lien vers notre fichier image 
      FileInputStream stream = new FileInputStream(file); 
  
      //préparation de l'instruction SQL 
      String sql = "INSERT INTO TableImages VALUES (?, ?)"; 
      PreparedStatement statement = connection.prepareStatement(sql); 
  
      //insertion de l'image 
      statement.setString(1, nom); 
      statement.setBinaryStream(2, stream, (int)file.length()); 
      statement.executeUpdate(); 
  
    }catch(Exception e){ 
       //traitement des erreurs SQL, IO, etc. 
    }finally { 
       //fermeture de la connexion, du flux, etc. 
    } 
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
public static void extraireImage(String nom, String chemin) { 
   String destination = chemin + System.getProperty("file.separator") 
                         + nom + ".jpg"; 
   File file = new File(destination); 
   try{ 
      //lien vers la base de données 
      Connection connection = DriverManager.getConnection("url","user","password"); 
  
      //préparation de l'instruction SQL 
      String sql = "SELECT * FROM TableImages WHERE nom = ? "; 
      PreparedStatement statement = connection.prepareStatement(sql); 
  
      //récupération de l'image (BLOB) 
      statement.setString(1, nom); 
      ResultSet resultat = statement.executeQuery(); 
      resultat.first(); 
      Blob blob = resultat.getBlob("images"); 
  
      //lecture du blob et écriture sur le disque 
      BufferedImage image = ImageIO.read(blob.getBinaryStream()); 
      FileOutputStream stream = new FileOutputStream(file); 
      ImageIO.write(image,"jpg",stream);   
  
    }catch(Exception e){ 
       //traitement des erreurs SQL, IO, etc. 
    }finally { 
       //fermeture de la connexion, du flux, etc. 
    } 
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
public static void insererTexte(String nomFichier){ 
   File file = new File(nomFichier); 
   BufferedReader fileReader = null; 
   String texte = ""; 
   StringReader stringReader = null; 
   Connection connection = null; 
   PreparedStatement statement = null; 
   try{ 
      //lectute du contenu du fichier à insérer 
      fileReader = new BufferedReader(new FileReader(file)); 
      String ligne = null; 
      while((ligne = fileReader.readLine()) != null){ 
         texte += ligne+"\n"; 
      } 
  
      //préparation de la connexion 
      connection = DriverManager.getConnection("url","login","pass"); 
      String sql = "INSERT INTO ClobTable (nom,article) VALUES (?, ?)"; 
      statement = connection.prepareStatement(sql); 
  
      //on met en place les paramètres du statement 
      statement.setString(1,file.getName()); 
      stringReader = new StringReader(texte); 
      statement.setCharacterStream(2,stringReader,texte.length()); 
  
      //exécution de l'instruction 
      statement.executeUpdate(); 
  
   }catch(Exception e){ 
      e.printStackTrace(); 
   }finally{ 
      try{fileReader.close();}catch(Exception e){} 
      try{stringReader.close();}catch(Exception e){} 
      try{statement.close();}catch(Exception e){} 
      try{connection.close();}catch(Exception e){} 
   } 
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
public static void lectureTexte(String nomArticle){ 
   BufferedReader clobReader = null; 
   Connection connection = null; 
   PreparedStatement statement = null; 
   ResultSet resultset = null; 
   try{ 
      //préparation de la connexion 
      connection = DriverManager.getConnection("url","login","pass"); 
      String sql = "SELECT article FROM ClobTable WHERE nom = ?"; 
      statement = connection.prepareStatement(sql); 
  
      //on met en place les paramètres du statement 
      statement.setString(1,nomArticle); 
  
      //exécution de la requête 
      resultset = statement.executeQuery(); 
  
      //récupération et lecture du clob 
      if(resultset.next()){ 
         Clob clob = resultset.getClob("article"); 
         clobReader = new BufferedReader(clob.getCharacterStream()); 
         String ligne = null; 
         while((ligne = clobReader.readLine()) != null){ 
            System.out.println(ligne); 
         } 
      }else{ 
         System.out.println("Article "+nomArticle+" introuvable"); 
      } 
   }catch(Exception e){ 
      e.printStackTrace(); 
   }finally{ 
      try{clobReader.close();}catch(Exception e){} 
      try{resultset.close();}catch(Exception e){} 
      try{statement.close();}catch(Exception e){} 
      try{connection.close();}catch(Exception e){} 
   } 
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
public static void rechercherTexte(String recherche){ 
   Connection connection = null; 
   Statement statement = null; 
   ResultSet resultset = null; 
   try{ 
      //préparation de la connexion 
      connection = DriverManager.getConnection("url","login","pass"); 
      statement = connection.createStatement(); 
  
      //exécution de la requête 
      String sql = "SELECT * FROM ClobTable"; 
      resultset = statement.executeQuery(sql); 
  
      //recherche dans les différents clob 
      while(resultset.next()){ 
         String nomArticle = resultset.getString("nom"); 
         System.out.println("Recherche de "+recherche+" dans "+nomArticle); 
         Clob clob = resultset.getClob("article"); 
         long indexe = 1;//Attention : le premier caractère est d'indexe 1 
         while((indexe = clob.position(recherche,indexe)) != -1){ 
            System.out.println("  mot trouvé en "+indexe); 
            indexe++; 
            //ne pas oublier d'incrémenter l'index 
         } 
      } 
   }catch(Exception e){ 
      e.printStackTrace(); 
   }finally{ 
      try{resultset.close();}catch(Exception e){} 
      try{statement.close();}catch(Exception e){} 
      try{connection.close();}catch(Exception e){} 
   } 
}

1
2
3
4
5
6
CREATE TYPE PERSONNE 
  ( 
    NOM VARCHAR(40), 
    PRENOM VARCHAR(40), 
    AGE INTEGER 
 );

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
public class Personne implements SQLData{ 
   private String nom;  
   private String prenom; 
   private int age; 
   private String typeSql;  
  
   //Définition des constructeurs 
  
   //Définition des getters/setters 
  
   //Implémentation de SQLData 
    public String getSQLTypeName() { 
      return typeSql; 
    } 
    public void readSQL(SQLInput stream, String type) 
                        throws SQLException { 
      typeSql = type; 
      nom = stream.readString(); 
      prenom = stream.readString(); 
      age = stream.readInt(); 
   } 
  
    public void writeSQL(SQLOutput stream)  
     throws SQLException { 
      stream.writeString(nom); 
      stream.writeString(prenom); 
      stream.writeInt(age); 
   } 
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
Connection connection = ...;  
  
// mise en place du mapping 
Map map = con.getTypeMap(); 
map.put("Schema.PERSONNE", Class.forName("Personne"); 
  
// utilisation 
Statement statement = ...;  
String sql = "SELECT Personnes FROM Annuaire"; 
ResultSet resultset = statement.executeQuery(sql); 
while(resultset.next()){ 
   Personne personne = (Personne)resultset.getObject(1); 
   System.out.println("Nom = "+personne.getNom()); 
   System.out.println("Prenom = "+personne.getPrenom()); 
   System.out.println("Age  = "+personne.getAge()); 
}

1
2
3
4
5
6
7
8
9
10
11
public static void afficheTypeColonne(ResultSet rs) { 
	String nomColonne = null; 
	String type = null; 
	ResultSetMetaData rsmd = rs.getMetaData (); 
	int nbCol = rsmd.getColumnCount (); 
	for (int i = 0; i < nbCol; i++) { 
		nomColonne = rsmd.getColumnLabel(i + 1); 
		type = rsmd.getColumnTypeName(i + 1); 
		System.out.println("Colonne: "+nomColonne+" de type: "+type); 
	} 
}