Connecting to MySQL via JAVA

This article shows the example JAVA code for connecting to MySQL.

Before you start, you need to add MySQL connector package to your Java project. The download link for the MySQL connector is https://dev.mysql.com/downloads/connector/j/.

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class MysqlConnection {

    public static void main(String[] args) {
        Connection conn = null;
        String dbServer = "mysql-xxxxx-0.cloudclusters.net"; // change it to your database server name
        int dbPort = 15253; // change it to your database server port
        String dbName = "your database name";
        String userName = "your database user name";
        String password = "your database password";
        String url = String.format("jdbc:mysql://%s:%d?user=%s&password=%s", 
                                    dbServer, dbPort, userName, password);
        try {

            // Attention:
            // You need to change the driver name to "com.mysql.jdbc.Driver"
            // if your MySQL connector version is lower than 8.0.
            Class.forName("com.mysql.cj.jdbc.Driver");
            conn = DriverManager.getConnection(url);
            Statement stmt = conn.createStatement();
            // change database
            String sqlusedb = "use " + dbName;
            int result = stmt.executeUpdate(sqlusedb);

            // create table
            String sql = "create table teacher(NO char(20), name varchar(20),primary key(NO))";
            result = stmt.executeUpdate(sql);

            // insert data
            if (result != -1) {
                sql = "insert into teacher(NO,name) values('202001','ben')";
                result = stmt.executeUpdate(sql);
                sql = "insert into teacher(NO,name) values('202002','ethan')";
                result = stmt.executeUpdate(sql);
            }

            // query data
            sql = "select * from teacher";
            ResultSet rs = stmt.executeQuery(sql);
            System.out.println("No.\tName");
            while (rs.next()) {
                System.out.println(rs.getString(1) + "\t" + rs.getString(2));
            }
        } catch (SQLException e) {
            System.out.println("MySQL connection had an exception");
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}