$
This commit is contained in:
pro.boooooo
@@ -1,180 +1,180 @@
|
||||
package Test;
|
||||
|
||||
/* [BPakage.BDatabase]
|
||||
* Desc: To create Operationnal Database Link fast :)
|
||||
* GitHub: https://github.com/lalBi94
|
||||
* Created by: Bilal Boudjemline
|
||||
* 28/09/2022 at 20:35
|
||||
* */
|
||||
|
||||
import java.sql.*;
|
||||
import java.sql.Connection;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Arrays;
|
||||
import java.util.Iterator;
|
||||
import org.mariadb.jdbc.*;
|
||||
|
||||
import javax.crypto.spec.PSource;
|
||||
|
||||
/**
|
||||
* <p>Methodes pour les interaction avec une base de donnees</p>
|
||||
*
|
||||
* @author <a href="https://github.com/lalBi94">Bilal Boudjemline</a>
|
||||
*/
|
||||
|
||||
public class BDatabase {
|
||||
private final String db_host;
|
||||
private final String db_name;
|
||||
private final String db_user;
|
||||
private final String db_password;
|
||||
protected Connection sharedObject;
|
||||
private boolean status;
|
||||
|
||||
public BDatabase() {
|
||||
this.db_host = "jdbc:mariadb://dwarves.iut-fbleau.fr/";
|
||||
this.db_name = "brinet";
|
||||
this.db_user = "brinet";
|
||||
this.db_password = "Aignan41!";
|
||||
|
||||
try {
|
||||
Class.forName("org.mariadb.jdbc.Driver");
|
||||
} catch(ClassNotFoundException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
|
||||
try {
|
||||
this.sharedObject = DriverManager.getConnection(this.db_host + this.db_name, this.db_user, this.db_password);
|
||||
this.status = true;
|
||||
} catch (SQLException e) {
|
||||
System.out.println("Erreur de liaison avec la base de donnees.");
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Recuperer les informations d'un requete de type SELECT.
|
||||
*
|
||||
* @param request Le SELECT a faire (il y aura plus d'argument prochainement)
|
||||
* @return Les resultats engendre par la requete
|
||||
*/
|
||||
public ArrayList<String> fetchAll(String request) {
|
||||
try {
|
||||
ArrayList<String> toReturn = new ArrayList<String>();
|
||||
ResultSet rs = this.sharedObject.prepareStatement(request).executeQuery();
|
||||
|
||||
for(int i = 0; rs.next(); i++) {
|
||||
toReturn.add(i, String.valueOf(rs.getString(1)));
|
||||
}
|
||||
|
||||
return toReturn;
|
||||
} catch(SQLException e) {
|
||||
System.out.println("Erreur de la requete : " + e);
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Insert une ligne dans une table.
|
||||
*
|
||||
* @param table La table
|
||||
* @param col Tableau qui contient les colonnes d'affectation
|
||||
* @param value Valeur des colonnes
|
||||
* @return Retourne true si ca a reussit et false dans le cas inverse
|
||||
*/
|
||||
public boolean insertRow(String table, String[] col, String[] value) {
|
||||
StringBuilder collumns = new StringBuilder();
|
||||
StringBuilder values = new StringBuilder();
|
||||
Iterator<String> iteCol = Arrays.stream(col).iterator();
|
||||
Iterator<String> iteVal = Arrays.stream(value).iterator();
|
||||
|
||||
collumns.append("(");
|
||||
while(iteCol.hasNext()) {
|
||||
collumns.append(iteCol.next()).append(", ");
|
||||
}
|
||||
collumns.setLength(collumns.length()-2);
|
||||
collumns.append(")");
|
||||
|
||||
values.append("(");
|
||||
while(iteVal.hasNext()) {
|
||||
values.append("\"").append(iteVal.next()).append("\"").append(", ");
|
||||
}
|
||||
values.setLength(values.length()-2);
|
||||
values.append(")");
|
||||
|
||||
String request = "INSERT INTO " + table + collumns + " VALUES" + values + ";";
|
||||
System.out.println(request);
|
||||
|
||||
try {
|
||||
this.sharedObject.prepareStatement(request).executeQuery();
|
||||
System.out.println("Succes: " + request);
|
||||
return true;
|
||||
} catch(SQLException e) {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Faire des requetes de type UPDATE SET (il y aura plus d'argument prochainement).
|
||||
*
|
||||
* @param request La requete
|
||||
* @return Si oui ou non ca a fonctionne
|
||||
*/
|
||||
public boolean updateRow(String request) {
|
||||
try {
|
||||
this.sharedObject.prepareStatement(request).executeQuery();
|
||||
System.out.println("Succes: " + request);
|
||||
return true;
|
||||
} catch(SQLException e) {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Recuperer l'objet Connection pour pouvoir utiliser ses methodes.
|
||||
*
|
||||
* @return L 'objet Connection.
|
||||
*/
|
||||
public Connection getSharedObject() {
|
||||
return this.sharedObject;
|
||||
}
|
||||
|
||||
/**
|
||||
* Recuperer l'utilisateur courant.
|
||||
*
|
||||
* @return L 'utilisateur.
|
||||
*/
|
||||
public String getUser() {
|
||||
return this.db_user;
|
||||
}
|
||||
|
||||
/**
|
||||
* Recuperer l'hote courant.
|
||||
*
|
||||
* @return L 'hote.
|
||||
*/
|
||||
public String getHost() {
|
||||
return this.db_host;
|
||||
}
|
||||
|
||||
/**
|
||||
* Recuperer le nom de la base de donnees.
|
||||
*
|
||||
* @return Le nom de la base de donnees.
|
||||
*/
|
||||
public String getDatabaseName() {
|
||||
return this.db_name;
|
||||
}
|
||||
|
||||
/**
|
||||
* Recuperer le status de connection.
|
||||
*
|
||||
* @return Le status de connection.
|
||||
*/
|
||||
public boolean getStatus() {
|
||||
return this.status;
|
||||
}
|
||||
|
||||
@Override
|
||||
public String toString() {
|
||||
return this.db_host + "\n" + this.db_name + "\n" + this.db_user + "\n";
|
||||
}
|
||||
package Test;
|
||||
|
||||
/* [BPakage.BDatabase]
|
||||
* Desc: To create Operationnal Database Link fast :)
|
||||
* GitHub: https://github.com/lalBi94
|
||||
* Created by: Bilal Boudjemline
|
||||
* 28/09/2022 at 20:35
|
||||
* */
|
||||
|
||||
import java.sql.*;
|
||||
import java.sql.Connection;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Arrays;
|
||||
import java.util.Iterator;
|
||||
import org.mariadb.jdbc.*;
|
||||
|
||||
import javax.crypto.spec.PSource;
|
||||
|
||||
/**
|
||||
* <p>Methodes pour les interaction avec une base de donnees</p>
|
||||
*
|
||||
* @author <a href="https://github.com/lalBi94">Bilal Boudjemline</a>
|
||||
*/
|
||||
|
||||
public class BDatabase {
|
||||
private final String db_host;
|
||||
private final String db_name;
|
||||
private final String db_user;
|
||||
private final String db_password;
|
||||
protected Connection sharedObject;
|
||||
private boolean status;
|
||||
|
||||
public BDatabase() {
|
||||
this.db_host = "jdbc:mariadb://dwarves.iut-fbleau.fr/";
|
||||
this.db_name = "brinet";
|
||||
this.db_user = "brinet";
|
||||
this.db_password = "Aignan41!";
|
||||
|
||||
try {
|
||||
Class.forName("org.mariadb.jdbc.Driver");
|
||||
} catch(ClassNotFoundException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
|
||||
try {
|
||||
this.sharedObject = DriverManager.getConnection(this.db_host + this.db_name, this.db_user, this.db_password);
|
||||
this.status = true;
|
||||
} catch (SQLException e) {
|
||||
System.out.println("Erreur de liaison avec la base de donnees.");
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Recuperer les informations d'un requete de type SELECT.
|
||||
*
|
||||
* @param request Le SELECT a faire (il y aura plus d'argument prochainement)
|
||||
* @return Les resultats engendre par la requete
|
||||
*/
|
||||
public ArrayList<String> fetchAll(String request) {
|
||||
try {
|
||||
ArrayList<String> toReturn = new ArrayList<String>();
|
||||
ResultSet rs = this.sharedObject.prepareStatement(request).executeQuery();
|
||||
|
||||
for(int i = 0; rs.next(); i++) {
|
||||
toReturn.add(i, String.valueOf(rs.getString(1)));
|
||||
}
|
||||
|
||||
return toReturn;
|
||||
} catch(SQLException e) {
|
||||
System.out.println("Erreur de la requete : " + e);
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Insert une ligne dans une table.
|
||||
*
|
||||
* @param table La table
|
||||
* @param col Tableau qui contient les colonnes d'affectation
|
||||
* @param value Valeur des colonnes
|
||||
* @return Retourne true si ca a reussit et false dans le cas inverse
|
||||
*/
|
||||
public boolean insertRow(String table, String[] col, String[] value) {
|
||||
StringBuilder collumns = new StringBuilder();
|
||||
StringBuilder values = new StringBuilder();
|
||||
Iterator<String> iteCol = Arrays.stream(col).iterator();
|
||||
Iterator<String> iteVal = Arrays.stream(value).iterator();
|
||||
|
||||
collumns.append("(");
|
||||
while(iteCol.hasNext()) {
|
||||
collumns.append(iteCol.next()).append(", ");
|
||||
}
|
||||
collumns.setLength(collumns.length()-2);
|
||||
collumns.append(")");
|
||||
|
||||
values.append("(");
|
||||
while(iteVal.hasNext()) {
|
||||
values.append("\"").append(iteVal.next()).append("\"").append(", ");
|
||||
}
|
||||
values.setLength(values.length()-2);
|
||||
values.append(")");
|
||||
|
||||
String request = "INSERT INTO " + table + collumns + " VALUES" + values + ";";
|
||||
System.out.println(request);
|
||||
|
||||
try {
|
||||
this.sharedObject.prepareStatement(request).executeQuery();
|
||||
System.out.println("Succes: " + request);
|
||||
return true;
|
||||
} catch(SQLException e) {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Faire des requetes de type UPDATE SET (il y aura plus d'argument prochainement).
|
||||
*
|
||||
* @param request La requete
|
||||
* @return Si oui ou non ca a fonctionne
|
||||
*/
|
||||
public boolean updateRow(String request) {
|
||||
try {
|
||||
this.sharedObject.prepareStatement(request).executeQuery();
|
||||
System.out.println("Succes: " + request);
|
||||
return true;
|
||||
} catch(SQLException e) {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Recuperer l'objet Connection pour pouvoir utiliser ses methodes.
|
||||
*
|
||||
* @return L 'objet Connection.
|
||||
*/
|
||||
public Connection getSharedObject() {
|
||||
return this.sharedObject;
|
||||
}
|
||||
|
||||
/**
|
||||
* Recuperer l'utilisateur courant.
|
||||
*
|
||||
* @return L 'utilisateur.
|
||||
*/
|
||||
public String getUser() {
|
||||
return this.db_user;
|
||||
}
|
||||
|
||||
/**
|
||||
* Recuperer l'hote courant.
|
||||
*
|
||||
* @return L 'hote.
|
||||
*/
|
||||
public String getHost() {
|
||||
return this.db_host;
|
||||
}
|
||||
|
||||
/**
|
||||
* Recuperer le nom de la base de donnees.
|
||||
*
|
||||
* @return Le nom de la base de donnees.
|
||||
*/
|
||||
public String getDatabaseName() {
|
||||
return this.db_name;
|
||||
}
|
||||
|
||||
/**
|
||||
* Recuperer le status de connection.
|
||||
*
|
||||
* @return Le status de connection.
|
||||
*/
|
||||
public boolean getStatus() {
|
||||
return this.status;
|
||||
}
|
||||
|
||||
@Override
|
||||
public String toString() {
|
||||
return this.db_host + "\n" + this.db_name + "\n" + this.db_user + "\n";
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user