2017.08.25 12:13 Networking in Java 02

I learned how to connect to MySQL servers using a configuration file/username, port, and password.

It was hard to find, but using the following source of code(from zHorse, coded by Zedd7), I was able to rig something

so that I was able to connect to a local database of mine, on a unix server.

The following code just connects to the database, and I am still trying to send messages/values into the database.

The zHorse plugin is very useful as it uses many different database connectors, and I am thankful to Zedd7 for releasing the source code online.

I will be trying to find out how to send values.

public class MySQLConnector extends SQLDatabaseConnector {

	private static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
	private static final String JDBC_OPTIONS = "?verifyServerCertificate=false&useSSL=true&autoReconnect=true&failOverReadOnly=false";
	private static final String JDBC_URL = "jdbc:mysql://%s:%d/%s" + JDBC_OPTIONS;
	
	private String host;
	private int port;
	private String user;
	private String password;
	private String name;
	private String url;

	public MySQLConnector(ZHorse zh) {
		super(zh);
		host = zh.getCM().getDatabaseHost();
		port = zh.getCM().getDatabasePort();
		user = zh.getCM().getDatabaseUser();
		password = zh.getCM().getDatabasePassword();
		name = zh.getCM().getDatabaseName();
		tablePrefix = zh.getCM().getDatabaseTablePrefix();
		if (host != null && port != 0 && user != null && password != null && name != null && tablePrefix != null) {
			url = String.format(JDBC_URL, host, port, name);
			try {
				Class.forName(JDBC_DRIVER);
				openConnection();
			} catch (SQLException e) {
				zh.getLogger().severe(String.format("Failed to open connection with %s !", url));
				zh.getLogger().severe("Verify that the database is created and that the user has access with given password.");
				e.printStackTrace();
				connected = false;
			} catch (ClassNotFoundException e) {
				//e.printStackTrace();
			}
		}
		else {
			zh.getLogger().severe("Could not connect to the database because your config is incomplete !");
		}
	}
	
	@Override
	public void openConnection() throws SQLException {									
		connection = DriverManager.getConnection(url, user, password);
		connected = true;
	}
	
}