From 92c93dc9b03063d1fbe533666fb1db96aab0a46d Mon Sep 17 00:00:00 2001 From: NicolasFabregas Date: Wed, 16 Dec 2020 18:36:43 +0100 Subject: [PATCH] commit 2 : plein de tests dans createdatabase et getConnection --- src/main/java/fr/myny/database/DataBase.java | 137 ++++++++++++++++++- 1 file changed, 134 insertions(+), 3 deletions(-) diff --git a/src/main/java/fr/myny/database/DataBase.java b/src/main/java/fr/myny/database/DataBase.java index 1a7a1ba..31550ca 100644 --- a/src/main/java/fr/myny/database/DataBase.java +++ b/src/main/java/fr/myny/database/DataBase.java @@ -1,11 +1,19 @@ package fr.myny.database; +import java.sql.*; +import java.util.*; +import java.io.*; +import java.util.concurrent.*; +import com.mysql.jdbc.Driver; + +import javax.sql.DataSource; + /** * La classe DataBase qui soccupera de la base de donnees */ public class DataBase { - + Connection connexion; /** @@ -23,7 +31,7 @@ public class DataBase { } /** - * La methode d'import de donnees depuis la base de donnees + * La methode dimport de donnees depuis la base de donnees */ public void importDataBase(){ @@ -32,8 +40,117 @@ public class DataBase { /** * La methode de creation de la base de donnees */ - public void createDataBase(){ + public void createDataBase(String fileName) { + /*String url = "jdbc:sqlite:C:/Users/W7/Desktop/" + fileName; + try (Connection conn = DriverManager.getConnection(url)) { + if (conn != null) { + DatabaseMetaData meta = conn.getMetaData(); + System.out.println("The driver name is " + meta.getDriverName()); + System.out.println("A new database has been created."); + } + } catch (SQLException e) { + System.out.println(e.getMessage()); + }*/ + //Class.forName("com.mysql.jdbc.Driver"); + /*try(Connection myCo = DriverManager.getConnection("jdbc:raima:rdm://C:/Users/W7/IdeaProjects/ProjetGenieLogicielLoto/src/"+fileName)){ + try(Statement mySt = myCo.createStatement()){ + mySt.execute("Create DataBase Test_DB"); + mySt.execute("Create Table Test_Table(" + + "annee_numero_de_tirage(integer)," + + "jour_de_tirage(char(10))," + + "date_de_tirage(Date)," + + "date_de_forclusion(Date)," + + "boule_1(tinyint)," + + "boule_2(tinyint)," + + "boule_3(tinyint)," + + "boule_4(tinyint)," + + "boule_5(tinyint)," + + "numero_chance(tinyint)," + + "combinaison_gagnante_en_ordre_croissant(char(20))," + + "nombre_de_gagnant_au_rang1(integer)," + + "rapport_du_rang1(integer)," + + "nombre_de_gagnant_au_rang2(integer)," + + "rapport_du_rang2(integer)," + + "nombre_de_gagnant_au_rang3(integer)," + + "rapport_du_rang3(integer)," + + "nombre_de_gagnant_au_rang4(integer)," + + "rapport_du_rang4(integer)," + + "nombre_de_gagnant_au_rang5(integer)," + + "rapport_du_rang5(integer)," + + "nombre_de_gagnant_au_rang6(integer)," + + "rapport_du_rang6(integer)," + + "numero_jokerplus(integer),"+ + "devise(char(3)),"+ + ")"); + myCo.commit(); + mySt.close(); + } + catch(Exception e){ + System.out.println(e); + } + finally { + + } + myCo.close(); + */ + /*} + catch (SQLException sqle) { + System.out.println(sqle); + }*/ + /*try { + String line; + Process p = Runtime.getRuntime().exec("C:/Users/W7/Desktop/database.sql"); + BufferedReader input = new BufferedReader(new InputStreamReader(p.getInputStream())); + while ((line = input.readLine()) != null) { + System.out.println(line); + } + input.close(); + } + catch (Exception err) { + err.printStackTrace(); + }*/ + /*loadDatabase(); + + try { + PreparedStatement preparedStatement = connexion.prepareStatement("INSERT INTO noms(nom, prenom) VALUES(?, ?);"); + preparedStatement.setString(1, utilisateur.getNom()); + preparedStatement.setString(2, utilisateur.getPrenom()); + + preparedStatement.executeUpdate(); + } catch (SQLException e) { + e.printStackTrace(); + }*/ + + try { + Class.forName("com.mysql.jdbc.Driver"); + } + catch (ClassNotFoundException e) { + } + + try { + connexion = DriverManager.getConnection("jdbc:mysql://localhost:3306"); + } catch (SQLException e) { + System.out.println("oskour " +e.getStackTrace()); + } + + Statement statement = null; + ResultSet resultat = null; + try { + statement = connexion.createStatement(); + + // Exécution de la requête + resultat = statement.executeQuery("SELECT nom, prenom FROM noms;"); + + // Récupération des données + while (resultat.next()) { + String nom = resultat.getString("nom"); + String prenom = resultat.getString("prenom"); + } + } + catch (SQLException e) { + System.out.println(e); + } } @@ -43,4 +160,18 @@ public class DataBase { public void updateDataBase(){ } + public Connection getConnection() throws SQLException { + Connection conn = null; + Properties connectionProps = new Properties(); + connectionProps.put("user", "w7"); + connectionProps.put("password", "asCVhik;9$"); + if (this.dbms.equals("mysql")) { + conn = DriverManager.getConnection( + "jdbc:" + this.dbms + "://" + this.serverName + ":" + this.portNumber + "/", connectionProps); + } else if (this.dbms.equals("derby")) { + conn = DriverManager.getConnection("jdbc:" + this.dbms + ":"+this.dbName +";create=true", connectionProps); + } + System.out.println("Connected to database"); + return conn; + } }