Java и MySQL - SBP-Program

Рассмотрим пример, который свяжет Java-приложение с СУБД MySQL (Java MySQL). Работать будем в среде Eclipse.

Что нам понадобится

Eclipse.

Где взять Eclipse? Eclipse скачать можно с www.eclipse.org Бесплатно.

Java. Java должна быть установлена до установки Eclipse.

Где взять Java? Java скачать можно с www.oracle.com бесплатно.

СУБД MySQL.

Где взять MySQL? MySQL скачать можно с www.mysql.com. Бесплатно.

Ещё понадобится JDBC драйвер MySQL, который на сайте называется MySQL Connector/J 5.0.8 (если есть более новый, то берите его), а загруженный на компьютер файл драйвера называется mysql-connector-java-5.0.8.

Где взять MySQL Connector/J? MySQL Connector/J скачать можно с https://dev.mysql.com/downloads/. Бесплатно.

Драйвер MySQL Connector/J нужен для связи Java – приложения и MySQL базы данных.

MySQL

Установите MySQL. Я при установке не менял никаких настроек, предложенных мастером. Результат на картинке: java-mysql

MySQL Connector/J

Распакуйте дистрибутив mysql-connector-java-5.0.8 в любой каталог. Я распаковал его в папку MySQL_Connector диска «H», получил вот что:

Файл mysql-connector-java-5.0.8-bin из распакованного дистрибутива скопируйте в папку (в моём случае) H:Program FilesJavajre1.6.0_02libext, а вы в свою папку ext:

Java+ MySQL Connector/J + MySQL

Начинаем работать с Eclipse. Открываем Eclipse SDK. В правом верхнем углу должна быть кнопка Java, как на рисунке. Если этого нет, тогда Window -> Open Perspective -> Java. Java+ MySQL Connector/J + MySQL

Создадим проект: File->New->Java Project или File->New->Project… и в открывшемся окне выбираем Java Project, жмём Next. В поле Project Name укажем MySQLProject, жмём Finish. Слева в виде Package Explorer получаем: MySQL

Правой кнопкой по src, в откывшемся меню выбираем New->Package. Имя пакета в поле Name установим app. Получаем: MySQL

Скачайте базу java-mysql (1Кб), распакуйте и поместите её в папку data севера MySQL. У меня получилось так: MySQL

Итак, что мы имеем? Мы создали проект MySQLProject, установили драйвер в jre/lib/ext, создали MySQL базу данных java-mysql и поместили её по адресу data сервера MySQL. Теперь мы готовы сделать приложение для работы с MySQL базой.

Правой кнопкой по пакету app -> New -> Class вводим имя класса KApplication, установим флаг public static void main. Полученный класс сделаем наследником JFrame и добавим поле serialVersionUID:

package app; import javax.swing.JFrame; public class KApplication extends JFrame { /** * */ private static final long serialVersionUID = 1L; /** * @param args */ public static void main(String[] args) { } }

Перейдём к модели, которая будет хранить информацию из базы данных.

AbstractTableModel

Добавим в пакет app класс модели KModel: правой кнопкой по пакету app -> New -> Class AbstractTableModel

Изменим код, созданный мастером следующим образом:

package app; import java.util.Vector; import javax.swing.table.AbstractTableModel; //www.sbp-program.ru public class KModel extends AbstractTableModel { private static final long serialVersionUID = 1L; //Имена колонок; protected Vector<String> columnNames; //Данные; private Vector<Vector<Object>> tableData; //Классы колонок; protected Vector<Object> vColClass; public KModel() { super(); vColClass = new Vector<Object>(); vColClass.add(0, Integer.class); vColClass.add(1, String.class); columnNames = new Vector<String>(); columnNames.add(«Номер»); columnNames.add(«Наименование»); } @Override public int getColumnCount() { return columnNames.size(); } @Override public int getRowCount() { return getTableData().size(); } @Override public Object getValueAt(int row, int column) { return getTableData().get(row).get(column); } //Показывать заголовки колонок; public String getColumnName(int column) { return columnNames.get(column); } //Запрещаем редактировать первую колонку (счёт колонок идёт с нуля); public boolean isCellEditable(int row, int column) { if(column == 0) { return false; } return true; } public void setValueAt(Object obj, int row, int column) { if(column == 0) { (getTableData().get(row)).set(column, (Integer)obj); } else if(column == 1) { (getTableData().get(row)).set(column, (String)obj); } fireTableCellUpdated(row, column); } public Class<?> getColumnClass(int col) { Class<?> c = Object.class; try { c = (Class<?>)vColClass.get(col); } catch (RuntimeException e) { System.out.println(e); } return c; } public void setTableData(Vector<Vector<Object>> tableData) { this.tableData = tableData; } public Vector<Vector<Object> getTableData() { return tableData; } }

Класс модели мы унаследовали от абстрактного класса AbstractTableModel, переопределив объявленные в нём методы и добавив два своих метода для работы с данными, хранящимися в модели: setTableData и getTableData.

Настало время создать класс, который и будет соединять нас с базой данных.

Java + MySQL

Напомню, наша база java-mysql работает под управлением СУБД MySQL, JDBC драйвер для этой СУБД называется MySQL Connector/J. Создадим класс, который соединит нас с базой данных. Правой кнопкой по пакету app -> New -> Class. Имя класса KFDB: KFDB

Изменим код класса KFDB, созданный мастером так:

package app; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; public class KFDB { private Connection con = null; public KFDB(String driver, String url, String login, String pass) { try { Class.forName(driver); con = DriverManager.getConnection(url, login, pass); } catch (ClassNotFoundException ex) { System.err.println(«KFDB.Cannot find this db driver classes.»); ex.printStackTrace(); } catch (SQLException e) { System.err.println(«KFDB.Cannot connect to this db.»); e.printStackTrace(); } } }

Мы объявили в конструкторе класса параметры:

driver – это имя нашего драйвера MySQL Connector/J;

url – адрес базы данных, у нас это адрес базы java-mysql;

pass – пароль.

В блоке try/catch загружаем статическим методом forName дравер для базы данных. Статическим методом getConnection устанавливаем соединение с нашей базой данных. Класс DriverManager управляет работой драйверов. Если драйвер, в нашем случае MySQL Connector/J, не обнаружится, то будет выброшено исключение ClassNotFoundException, а если DriverManager не сможет соединиться с нашей базой java-mysql, то будет выброшено исключение SQLException.

Поле con, имеющее тип Connection, можно представить как телефонный провод, по которому информация будет перетекать из нашего приложения в базу данных и обратно.

Получим по этому проводу информацию из базы данных. Введём поле st типа Statement. Это поле даст нам возможность обратиться к базе данных с каким-то конкретным запросом. Определим метод getNomen, который вернёт информацию из базы данных:

package app; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSetMetaData; import java.sql.SQLException; import java.sql.Statement; import java.sql.ResultSet; import java.util.Vector; //www.sbp-program.ru public class KFDB { private Connection con = null; public KFDB(String driver, String url, String login, String pass) { try { Class.forName(driver); con = DriverManager.getConnection(url, login, pass); } catch (ClassNotFoundException ex) { System.err.println(«KFDB.Cannot find this db driver classes.»); ex.printStackTrace(); } catch (SQLException e) { System.err.println(«KFDB.Cannot connect to this db.»); e.printStackTrace(); } } public Vector<Vector<Object>> getNomen(String query) { Vector<Vector<Object>> retVector = new Vector<Vector<Object>>(); try { Statement st = con.createStatement(); ResultSet rs = st.executeQuery(query); ResultSetMetaData rsmd = rs.getMetaData(); int cols = rsmd.getColumnCount(); while (rs.next()) { Vector<Object> newRow = new Vector<Object>(); for (int i = 1; i <= cols; i++) { newRow.add(rs.getObject(i)); } retVector.add(newRow); } rs.close(); st.close(); } catch (SQLException e) { System.err.println(«KFDB.There are problems with the query » + query); e.printStackTrace(); } return retVector; } }

В методе getNomen создаём объект Statement st, он позволит нам сделать запрос к базе, сам запрос выполняется методом executeQuery, который возвращает набор данных в виде объекта ResultSet rs. Этот набор данных можно представить как таблицу из базы данных, содержащую сами данные и информацию об этой таблице, например, сколько столбцов имеется в таблице. Информацию об устойстве полученного набора данных извлечём из объекта ResultSetMetaData rsmd. Нас интересует количество колонок в наборе данных. Для этого пишем строку: int cols = rsmd.getColumnCount(). Метод rs.next() перемещает нас по строкам набора данных. Получив первую строку, в цикле for извлекаем значение из каждой ячейки строки методом rs.getObject(i) и добавляем его в вектор newVector. Сформированный таким образом newVector добавляем в результирующий вектор retVector. Вектор retVector становится изображением набора данных rs.

Вернёмся к главному окну приложения,т.е. к классу KApplication, и приведём его код к виду(не забудьте указать вашего пользователя и пароль (у меня «root» и «masterkey» соответственно)):

package app; import java.awt.BorderLayout; import java.awt.Container; import javax.swing.JFrame; import javax.swing.JScrollPane; import javax.swing.JTable; public class KApplication extends JFrame { /** * */ private static final long serialVersionUID = 1L; private JTable table; private KModel model; private KFDB baza; public KApplication() { super(«Справочник.Номенклатура»); Container c = getContentPane(); //Не забудьте указать вашего пользователя и пароль (у меня «root» и «masterkey» соответственно); baza = new KFDB(«com.mysql.jdbc.Driver», «jdbc:mysql://localhost:3306/java-mysql», «root», «masterkey»); model = new KModel(); model.setTableData(baza.getNomen(«SELECT * FROM NOMENKLATURA»)); table = new JTable(model); table.getColumnModel().getColumn(0).setMaxWidth(50); c.add(new JScrollPane(table), BorderLayout.CENTER); setSize(400, 300); setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); setVisible(true); } /** * @param args */ public static void main(String[] args) { new KApplication(); } }

Компилируем и запускаем: правой кнопкой по классу KApplication -> Run As -> Java Application, получаем: Nomen