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
| import connectionpool.*
import java.sql.*
public class traiter {
public static void traiter() {
String url = "jdbc:oracle:thin:@localhost:.........";
String login = "....";
String password = ".......";
try{
Connection connection = DriverManager.getConnection(url,login,password);
PreparedStatement pstmt_fouille;
pstmt_fouille = dbc.prepareStatement("SELECT COUNT(id_fouille) AS nb FROM fouille WHERE num_ctv = ?");
pstmt_fouille.setString(1, chp_ctv);
ResultSet resultat_fouille = pstmt_fouille.executeQuery();
int r_fouille = -1;
if(resultat_fouille.next()) {
if(resultat_fouille.getInt("nb") != 0) {
pstmt_fouille = dbc.prepareStatement("SELECT id_fouille AS id_f FROM fouille WHERE num_ctv = ?");
pstmt_fouille.setString(1, chp_ctv);
resultat_fouille = pstmt_fouille.executeQuery();
if(resultat_fouille.next())
r_fouille = resultat_fouille.getInt("id_f");
}
else {
pstmt_fouille = dbc.prepareStatement("INSERT INTO fouille (id_fouille, num_ctv, id_ccs, id_date_deb_travaux , id_date_ferm_fouille, id_date_ouv_fouille, id_resp, id_numAdr, id_type_voie, id_nom_voie, id_CP, id_unite, id_numero_Aff, id_libelle_incident, id_entreprise, id_decompte, id_avance) VALUES (fouille_seq.NEXTVAL,?,?,?,?,?,?,?,?,?,?,?,?,?,?,null,null)");
pstmt_fouille.setString(1, chp_ctv);
pstmt_fouille.setInt(2, r_ccs);
pstmt_fouille.setInt(3, r_debTrav);
pstmt_fouille.setInt(4, r_finTrav);
pstmt_fouille.setInt(5, r_ouvFouille);
pstmt_fouille.setInt(6, r_nomResp);
pstmt_fouille.setInt(7, r_numAdr);
pstmt_fouille.setInt(8, r_typeVoie);
pstmt_fouille.setInt(9, r_nomVoie);
pstmt_fouille.setInt(10, r_CP);
pstmt_fouille.setInt(11, r_unite);
pstmt_fouille.setInt(12, r_affaire);
pstmt_fouille.setInt(13, r_libelle);
pstmt_fouille.setInt(14, r_nomEntreprise);
pstmt_fouille.executeUpdate();
pstmt_fouille = dbc.prepareStatement("SELECT id_fouille AS id_insert_fouille FROM fouille WHERE num_ctv = ?");
pstmt_fouille.setString(1, chp_ctv);
resultat_fouille = pstmt_fouille.executeQuery();
if(resultat_fouille.next())
r_fouille = resultat_fouille.getInt("id_insert_fouille");
}
}
} |
Partager