Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- <field name="company_id" type="anand_custom_definition" indexed="false" stored="true" required="true" multiValued="false" />
- <field name="project_name" type="anand_custom_definition" indexed="true" stored="true" required="true" multiValued="false" />
- public class JDBC {
- private static final String DB_URL = "jdbc:mysql://192.168.0.237:3306/anandDatabase?autoReconnect=true";
- private static final String USER_NAME = "anand";
- private static final String PASSWORD = "anand";
- private static final String SOLR_URL = "http://192.168.0.237:8983/solr/anandSampleCollection";
- private static SolrClient solrClient;
- private static final Logger lOGGER = Logger.getLogger(JDBC.class);
- public static void main(String[] args) {
- Connection conn = null;
- Statement stmt = null;
- try {
- Class.forName(MYSQL_DRIVER);
- conn = DriverManager.getConnection(DB_URL, USER_NAME, PASSWORD);
- stmt = conn.createStatement();
- String query = "SELECT id,public_id,name,description,code,company_id FROM project p";
- ResultSet rs = stmt.executeQuery(query);
- ResultSetMetaData resultSetMetaData = rs.getMetaData();
- int numColumns = resultSetMetaData.getColumnCount();
- String[] colNames = new String[numColumns + 1];
- int[] colNo = new int[numColumns + 1];
- for (int i = 1; i < (numColumns + 1); i++) {
- if (resultSetMetaData.getColumnName(i) != "null") {
- colNames[i] = resultSetMetaData.getColumnName(i);
- }
- }
- Collection<SolrInputDocument> docs = new ArrayList<SolrInputDocument>();
- solrClient = new HttpSolrClient(SOLR_URL.trim());
- System.out.println(solrClient.ping());
- while (rs.next()) {
- SolrInputDocument doc = new SolrInputDocument();
- doc.addField("project_company_id", rs.getInt("company_id"));
- solrClient.add(doc);
- docs.add(doc);
- doc = null;
- }
- UpdateResponse updateResponse = solrClient.commit();
- System.out.println(updateResponse.getStatus());
- rs.close();
- stmt.close();
- conn.close();
- } catch (Exception ex) {
- System.out.println("Error OCcurred"+ex.getMessage());
- ex.printStackTrace();
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement