Создание базы данных в MySQL

В настоящем пункте описывается последовательность команд, используемая для создания базы данных supplement в MySQL.

1.    

shell> <MySQL-home>\bin\mysql.exe -u root -p lifeisgood

2.                              supplement и делаем ее текущей:

mysql> CREATE DATABASE supplement;

mysql> USE supplement;

3.                              deliveries:

4.             

5.                  -> id MEDIUMINT NOT NULL AUTO_INCREMENT,

6.                  -> name VARCHAR(30) NOT NULL,

7.                  -> supplier VARCHAR(30) NOT NULL,

8.                  -> amount INT UNSIGNED DEFAULT '0' NOT NULL,

9.                  -> price DOUBLE(16, 2) DEFAULT '0.00' NOT NULL,

10.                 -> PRIMARY KEY (id)

11.                 -> );

12.                          suppliers:

13.            

14.                 -> id MEDIUMINT NOT NULL AUTO_INCREMENT,

15.                 -> name VARCHAR(30) NOT NULL,

16.                 -> account BIGINT NOT NULL,

17.                 -> first_name VARCHAR(30) NOT NULL,

18.                 -> last_name VARCHAR(30) NOT NULL,

19.                 -> second_name VARCHAR(30) NOT NULL,

20.                 -> PRIMARY KEY (id)

21.                 -> );

22.                          <MySQL-home>\data\deliveries.csv и <MySQL-home>\data\suppliers.csv (предполагается, что файлы были предварительно созданы и заполнены необходимыми данными):

mysql> LOAD DATA INFILE '../data/deliveries.csv' INTO TABLE deliveries;

mysql> LOAD DATA INFILE '../data/suppliers.csv' INTO TABLE suppliers;

23.                         

mysql> exit

Регистрация MySQL Connector/J

Создадим класс MySQLAccess, внутри которого инкапсулируем доступ к созданной в предыдущем пункте базе данных. Поместим его описание в файл <java-app-home>\MySQLAccess.java.

Для доступа к базам данных используется JDBC, а конкретное соединение предоставляется объектом класса DriverManager.DriverManager должен знать тип драйвера, используемого для работы с конкретной СУБД. Самый простой способ регистрации драйвера, это использовать Class.forName() для класса, реализующего интерфейс java.sql.Driver. Для MySQL Connector/J имя класса драйвера имеет вид com.mysql.jdbc.Driver.

В следующем фрагменте кода происходит регистрация MySQL драйвера.

...

  public static void main(String[] args) {

    ...

    try {

      // Регистрация драйвера MySQL

      Class.forName("com.mysql.jdbc.Driver").newInstance();

      ...

    } catch (Exception e) {

      e.printStackTrace(System.err);

    }

    ...

  }

...

Соединение с MySQL Database server из java-приложения

После того как мы зарегистрировали драйвер базы данных MySQL, можно установить соединение с сервером, используя метод getConnection() класса DriverManager. Указанный метод в качестве параметра принимает URL базы данных (хотя возможно дополнительно указать имя пользователя и пароль, см. документацию к классу). Метод возвращает класс-соединение Connection с базой данных.

В следующем фрагменте кода происходит установка соединения с базой данных supplement.

import java.sql.Connection;

import java.sql.DriverManager;

...

  public static void main(String[] args) {

    Connection conn = null;

    ...

    try {

      ...

      // Устанавливаем соединение с базой данных

      conn = DriverManager.getConnection("jdbc:mysql://localhost/supplement");

      ...

    } catch (Exception e) {

      e.printStackTrace(System.err);

    }

    ...

  }

...

Выполнение запроса к базе данных

Запрос к базе данных инкапсулируется внутри объекта класса Statement. В приведенном ниже фрагменте кода выполняется простой запрос к базе данных для получения всех записей таблицы deliveries. Результат запроса помещается в объект-хранилище ResultSet, содержимое которого затем выводится на консоль.

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

...

  public static void main(String[] args) {

    Connection conn = null;

    Statement stmt = null;

    ResultSet rs = null;

    try {

      ...

      // Создаем объект-выражение

      stmt = conn.createStatement();

      // Выполняем запрос к базе данных

      rs = stmt.executeQuery("SELECT * FROM deliveries");

      // Выводим на консоль значения 2-х полей полученных записей

      while (rs.next()) {

        System.out.println(rs.getString("id")

                                + ": " + rs.getString("price"));

      }

    } catch (Exception e) {

      e.printStackTrace(System.err);

    } finally {

      try {

        if (rs != null) { rs.close(); }

        if (stmt != null) { stmt.close(); }

        if (conn != null) { conn.close(); }

      } catch (SQLException e) {

        e.printStackTrace(System.err);

      }

    }

  }

...