Используйте файл jar Mysql ClusterJ для подключения к кластеру NDB - PullRequest
Новая
       19

Используйте файл jar Mysql ClusterJ для подключения к кластеру NDB

0 голосов
/ 31 октября 2018

Я следовал инструкции в руководстве ClusterJ здесь , чтобы подключиться к кластеру MySQL NDB с помощью API NDB. Ниже приведен пример кода того, что я делаю сейчас:

Main.java 

import com.mysql.clusterj.ClusterJHelper;
import com.mysql.clusterj.SessionFactory;
import com.mysql.clusterj.Session;
import com.mysql.clusterj.Query;
import com.mysql.clusterj.query.QueryBuilder;
import com.mysql.clusterj.query.QueryDomainType;
import java.io.File;
import java.io.InputStream;
import java.io.FileInputStream;
import java.io.*;
import java.util.Properties;
import java.util.List;

public class Main {
    public static void main (String[] args) throws
    java.io.FileNotFoundException,java.io.IOException {
     // Load the properties from the clusterj.properties file
     File propsFile = new File("clusterj.properties");
     InputStream inStream = new FileInputStream(propsFile);
     Properties props = new Properties();
     props.load(inStream);
     //Used later to get user input
     BufferedReader br = new BufferedReader(new InputStreamReader(System.in));

     // Create a session (connection to the database)
     SessionFactory factory = ClusterJHelper.getSessionFactory(props);
     Session session = factory.getSession();

    // Create and initialize an Employee
     Employee newEmployee = session.newInstance(Employee.class);
     newEmployee.setId(988);
     newEmployee.setFirst("John");
     newEmployee.setLast("Jones");
     newEmployee.setStarted("1 February 2009");
     newEmployee.setDepartment(666);

     // Write the Employee to the database
     session.persist(newEmployee);
}
}

Я сталкиваюсь с приведенной ниже ошибкой при попытке запустить это: 

java.lang.UnsatisfiedLinkError: no ndbclient in java.library.path
    at java.lang.ClassLoader.loadLibrary(ClassLoader.java:1867)
    at java.lang.Runtime.loadLibrary0(Runtime.java:870)
    at java.lang.System.loadLibrary(System.java:1122)
    at com.mysql.clusterj.tie.ClusterConnectionServiceImpl.loadSystemLibrary(ClusterConnectionServiceImpl.java:68)
    at com.mysql.clusterj.tie.ClusterConnectionServiceImpl.create(ClusterConnectionServiceImpl.java:87)
    at com.mysql.clusterj.core.SessionFactoryImpl.createClusterConnection(SessionFactoryImpl.java:335)
    at com.mysql.clusterj.core.SessionFactoryImpl.createClusterConnectionPool(SessionFactoryImpl.java:288)
    at com.mysql.clusterj.core.SessionFactoryImpl.<init>(SessionFactoryImpl.java:211)
    at com.mysql.clusterj.core.SessionFactoryImpl.getSessionFactory(SessionFactoryImpl.java:146)
    at com.mysql.clusterj.core.SessionFactoryServiceImpl.getSessionFactory(SessionFactoryServiceImpl.java:36)
    at com.mysql.clusterj.core.SessionFactoryServiceImpl.getSessionFactory(SessionFactoryServiceImpl.java:27)
    at com.mysql.clusterj.ClusterJHelper.getSessionFactory(ClusterJHelper.java:72)
    at com.mysql.clusterj.ClusterJHelper.getSessionFactory(ClusterJHelper.java:57)
    at com.pkg.mysql.Main.main(Main.java:27)

Ответы [ 2 ]

0 голосов
/ 16 апреля 2019

Добавить как аргументы vm или запустить, включая следующий путь

Для Mac: 

-Djava.library.path="/usr/local/mysql-{cluster-version}/lib/"

Для Windows: 

search for library path and replace inside double quotes
0 голосов
/ 04 ноября 2018

Ошибка возникает, поскольку ClusterJ требует файл ndb_engine.so в пути к классам Java.

Ссылка: http://ftp.nchu.edu.tw/MySQL/doc/ndbapi/en/mccj-getting.html

Я могу запустить программу, если укажу путь. 

# steps to compile and run the ndb java program on linux
javac -classpath /home/user1/clusterj-7.6.8.jar:. Main.java Employee.java
java -classpath /home/user1/clusterj-7.6.8.jar:. -Djava.library.path=/usr/lib64/mysql Main

Я все еще не смог найти способ решить эту проблему в среде Windows.

...