Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- int nul = 0;
- int total = 0;
- try {
- Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
- System.out.println("Driver O.K.");
- String url = "jdbc:sqlserver://BCNSDBA042\DEV_CP1_CI_AS";
- String user = "REMINDINTDATA";
- String passwd = "REMINDINTDATA";
- Connection conn = DriverManager.getConnection(url, user, passwd);
- System.out.println("Connexion effective !");
- Statement state = conn.createStatement();
- File indexDirectory = new File("D:\index\IdxDOSSIER\data\index");
- DirectoryReader r = DirectoryReader.open(FSDirectory
- .open(indexDirectory));
- int num = r.numDocs();
- System.out.println("clean en attente");
- state.executeUpdate("delete from Document_solr ");
- System.out.println("clean effectué");
- int i = 0;
- String commande = null;
- while (i < num) {
- commande = "INSERT INTO Document_solr (DC_KEY) VALUES";
- Document d = r.document(i);
- for (int k = 0; k < 100 && (i + k) < num; k++) {
- d = r.document(i + k);
- if ((i + k) == num - 1) {
- if (d.get("DC_KEY") != null) {
- commande = commande + "(" + d.get("DC_KEY") + ")";
- } else {
- commande = commande.substring(0,
- commande.length() - 1);
- nul++;
- }
- total++;
- } else {
- total++;
- d = r.document(i + k);
- if (d.get("DC_KEY") != null) {
- if (k != 99) {
- commande = commande + "(" + d.get("DC_KEY")
- + ")" + ",";
- } else {
- commande = commande + "(" + d.get("DC_KEY")
- + ")";
- }
- } else {
- nul++;
- k--;
- i++;
- }
- }
- }
- System.out.println("Fichier traiter : " + i);
- System.out.println(commande);
- state.executeUpdate(commande);
- i = i + 100;
- }
- r.close();
- state.close();
- // result.close();
- conn.close();
- } catch (Exception e) {
- e.printStackTrace();
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement