Search code examples
javamysqlapachejdbcolingo

jdbc connector for Apache Olingo


I have developed a JAVA Project using Apache Olingo in which i am trying to fetch data from MySQL Database but I am getting following error

Got an exception! com.mysql.jdbc.Driver

Which library is to be import for this in Apache olingo. Below is my Java Class

private EntityCollection getData(EdmEntitySet edmEntitySet){

           EntityCollection productsCollection = new EntityCollection();
           // check for which EdmEntitySet the data is requested
           if(DemoEdmProvider.ES_PRODUCTS_NAME.equals(edmEntitySet.getName())) {
               List<org.apache.olingo.commons.api.data.Entity> productList = productsCollection.getEntities();


               try
                {
                  // create our mysql database connection
                  //String myDriver = "org.gjt.mm.mysql.Driver";
                   String myDriver ="com.mysql.jdbc.Driver";
                  String myUrl = "jdbc:mysql://localhost:3306/testDB";
                  Class.forName(myDriver);
                  Connection conn = DriverManager.getConnection(myUrl, "root", "test1234");

                  // our SQL SELECT query. 
                  // if you only need a few columns, specify them by name instead of using "*"
                  String query = "SELECT * FROM Employee";

                  // create the java statement
                  Statement st = conn.createStatement();

                  // execute the query, and get a java resultset
                  ResultSet rs = st.executeQuery(query);

                  // iterate through the java resultset
                  while (rs.next())
                  {

                    String NAME = rs.getString("NAME");
                    String CITY = rs.getString("CITY");
                    int AGE = rs.getInt("AGE");

                    // print the results
                    final Entity e1 = new Entity()
                              .addProperty(new Property(null, "NAME", ValueType.PRIMITIVE, NAME))
                              .addProperty(new Property(null, "CITY", ValueType.PRIMITIVE, CITY))
                              .addProperty(new Property(null, "AGE", ValueType.PRIMITIVE,
                                 AGE));
                          e1.setId(createId("Products", 1));
                          productList.add(e1);
                  }
                  st.close();
                }
                catch (Exception e)
                {
                  System.err.println("Got an exception! ");
                  System.err.println(e.getMessage());
                }
           }

Solution

  • You can Add mysql connector Jar File link are: https://dev.mysql.com/downloads/connector/j/

    download and to import your project--> right click-->import -->File System -->Browse-->where are you store your connector