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 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228
|
public String addSiteToDataBase(Site mysite) throws SQLException, ClassNotFoundException {
con = base.connectDB();
Statement st = con.createStatement();
String sql = "insert into news(nomSite,categorie,favoris,lienRSS,url) values (?,?,?,?,?)";
try {
PreparedStatement ps
= con.prepareStatement(sql);
ps.setString(1, mysite.getNomSite());
ps.setString(2, mysite.getCategorie());
ps.setString(3, mysite.getFavoris());
ps.setString(4, mysite.getLienRSS());
ps.setString(5, mysite.getUrl());
ps.executeUpdate();
// st.close();
// con.close();
} catch (SQLException e) {
e.printStackTrace();
System.out.println("Erreur enregistrerSite " + e.getMessage());
}
finally{
try {
st.close();
}
catch(Exception ex){
}
}
//////////////////////
return "le site" + mysite.getNomSite() + "a été bien ajouté à la base de données";
}
//methode pour récupérer les catégories
public String catégorieFromDB() throws SQLException, ClassNotFoundException {
con = base.connectDB();
Statement stm = null;
ResultSet rs = null;
stm = con.createStatement();
listeCategorie.removeAll(listeCategorie);
String l = "1";
String sql = "select distinct categorie from news where favoris = 1 ";
rs = stm.executeQuery(sql);
try {
while (rs.next()) {
//Retrieve by column name
String categorie = rs.getString("categorie");
listeCategorie.add(categorie);
}
rs.close();
stm.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return "les catégories ont été récupérés ";
}
//***********methode pour recupere nom site préféré par catégorie
public void ListNomSiteParCateg(String categorie) throws SQLException, ClassNotFoundException {
con = base.connectDB();
Statement st = null;
ResultSet rs = null;
st = con.createStatement();
String l = "1";
String sql = "select nomSite from news where favoris = 1 and categorie='" + categorie + "'";
rs = st.executeQuery(sql);
try {
while (rs.next()) {
String nomS = rs.getString("nomSite");
listeNomSiteParCategorie.add(nomS);
}
rs.close();
st.close();
} catch (SQLException e) {
}
// rs.close();
// st.close();
}
//methode pour supprimer un site de la base de données
public String deleteSiteFromDataBase(String nomSite) throws SQLException, ClassNotFoundException {
con = base.connectDB();
String sql = "delete from news where nomSite ='" + nomSite + "' ";
try {
PreparedStatement ps = con.prepareStatement(sql);
ps.executeUpdate();
notifyObservers("" +getListePrincipale());
ps.close();
//con.commit();
con.close();
} catch (SQLException e) {
e.printStackTrace();
System.out.println("Erreur SupprimerSite " + e.getMessage());
}
return "le site " + nomSite + "a été bien supprimé de la base de données";
}
//methode pour mettre à jour le satatus des sites (de la liste principale a la liste des favoris)
public String prencipaleToPreferee(String nomSite) throws SQLException {
try {
con = base.connectDB();
} catch (ClassNotFoundException ex) {
Logger.getLogger(SiteManager.class.getName()).log(Level.SEVERE, null, ex);
}
String l = "1";
String sql = "UPDATE news SET favoris = 1 WHERE nomSite='"+nomSite+"' ";
try {
PreparedStatement ps = con.prepareStatement(sql);
ps.executeUpdate();
ps.close();
// con.close();
} catch (SQLException e) {
JOptionPane.showMessageDialog(null, e);
e.printStackTrace();
System.out.println("Erreur SupprimerSite " + e.getMessage());
}
// con.close();
System.out.println("le site a été ajouté à la liste prefere");
return "le site " + nomSite + "a été ajouté a la liste preferee";
}
//mmethode pour defavoriser un site
public String prefereeToPrencipale(String nomSite) throws SQLException {
try {
con = base.connectDB();
} catch (ClassNotFoundException ex) {
JOptionPane.showMessageDialog(null, ex);
Logger.getLogger(SiteManager.class.getName()).log(Level.SEVERE, null, ex);
}
System.out.println("requete update");
String sql = "UPDATE news SET favoris = 0 WHERE nomSite='"+nomSite+"' ";
try {
PreparedStatement ps = con.prepareStatement(sql);
ps.executeUpdate();
//con.commit();
ps.close(); //**************** l'erreur pointe ici
} catch (SQLException e) {
e.printStackTrace();
JOptionPane.showMessageDialog(null, e);
System.out.println("Erreur SupprimerSite " +e.getMessage());
}
//con.close();
System.out.println("le site a été ajouté à la liste principale");
return "le site " + nomSite + "a été ajouté a la liste principale";
}
//remplissage des listes
public String dbToListe() throws SQLException, ClassNotFoundException {
con = base.connectDB();
listePrincipale.removeAll(listePrincipale);
listeSiteFavoris.removeAll(listeSiteFavoris);
Statement stmt = null;
ResultSet rs = null;
stmt = con.createStatement();
String sql = "select * from news";
rs = stmt.executeQuery(sql);
// Extract data from result set
try {
while (rs.next()) {
//Retrieve by column name
String nomSite = rs.getString("nomSite");
String categorie = rs.getString("categorie");
String favoris = rs.getString("favoris");
String lienRSS = rs.getString("lienRSS");
String url = rs.getString("url");
System.out.println("nnbnbsnbqn" + nomSite);
Site s = new Site();
s.setNomSite(nomSite);
s.setLienRSS(lienRSS);
s.setCategorie(categorie);
s.setFavoris(favoris);
s.setUrl(url);
listePrincipale.add(s);
System.out.println(" taille liste princ" + listePrincipale.size());
if (favoris.equals("1")) {
listeSiteFavoris.add(s);
System.out.println(" taille" + listeSiteFavoris.size());
}
}
rs.close();
stmt.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
// stmt.close();
// con.close();
return "listes sont remplises";
} |
Partager