jdbc Apache Olingo 连接器

jdbc connector for Apache Olingo

我已经使用 Apache Olingo 开发了一个 JAVA 项目,我在其中尝试从 MySQL 数据库中获取数据,但出现以下错误

遇到异常! com.mysql.jdbc.Driver

要在 Apache olingo 中为此导入哪个库。下面是我的JavaClass

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());
                }
           }

您可以添加 mysql 连接器 Jar 文件 link 分别是:https://dev.mysql.com/downloads/connector/j/

下载并导入您的项目-->右键单击-->导入-->文件系统-->浏览-->你在哪里存储你的连接器