Advertisement
Guest User

Untitled

a guest
May 18th, 2016
74
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 2.31 KB | None | 0 0
  1. <field name="company_id" type="anand_custom_definition" indexed="false" stored="true" required="true" multiValued="false" />
  2. <field name="project_name" type="anand_custom_definition" indexed="true" stored="true" required="true" multiValued="false" />
  3.  
  4. public class JDBC {
  5. private static final String DB_URL = "jdbc:mysql://192.168.0.237:3306/anandDatabase?autoReconnect=true";
  6. private static final String USER_NAME = "anand";
  7. private static final String PASSWORD = "anand";
  8. private static final String SOLR_URL = "http://192.168.0.237:8983/solr/anandSampleCollection";
  9. private static SolrClient solrClient;
  10.  
  11. private static final Logger lOGGER = Logger.getLogger(JDBC.class);
  12.  
  13. public static void main(String[] args) {
  14. Connection conn = null;
  15. Statement stmt = null;
  16.  
  17. try {
  18. Class.forName(MYSQL_DRIVER);
  19. conn = DriverManager.getConnection(DB_URL, USER_NAME, PASSWORD);
  20. stmt = conn.createStatement();
  21. String query = "SELECT id,public_id,name,description,code,company_id FROM project p";
  22. ResultSet rs = stmt.executeQuery(query);
  23. ResultSetMetaData resultSetMetaData = rs.getMetaData();
  24. int numColumns = resultSetMetaData.getColumnCount();
  25. String[] colNames = new String[numColumns + 1];
  26. int[] colNo = new int[numColumns + 1];
  27.  
  28. for (int i = 1; i < (numColumns + 1); i++) {
  29. if (resultSetMetaData.getColumnName(i) != "null") {
  30. colNames[i] = resultSetMetaData.getColumnName(i);
  31. }
  32. }
  33. Collection<SolrInputDocument> docs = new ArrayList<SolrInputDocument>();
  34. solrClient = new HttpSolrClient(SOLR_URL.trim());
  35. System.out.println(solrClient.ping());
  36. while (rs.next()) {
  37. SolrInputDocument doc = new SolrInputDocument();
  38. doc.addField("project_company_id", rs.getInt("company_id"));
  39. solrClient.add(doc);
  40. docs.add(doc);
  41. doc = null;
  42. }
  43. UpdateResponse updateResponse = solrClient.commit();
  44. System.out.println(updateResponse.getStatus());
  45. rs.close();
  46. stmt.close();
  47. conn.close();
  48. } catch (Exception ex) {
  49. System.out.println("Error OCcurred"+ex.getMessage());
  50. ex.printStackTrace();
  51. }
  52. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement