Java и MySQL

Поддержка JavaScript отключена

SBP-Program

На главную -> Java -> Java и базы данных

&nbsp

]]>

Автор: Субботин Б.П.

Java и MySQL пример

Java и MySQL
MySQL
MySQL Connector/J
Java+ MySQL Connector/J + MySQL
AbstractTableModel
Java + MySQL

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

Где взять Eclipse? Eclipse скачать можно с http://www.eclipse.org/platform. Бесплатно. Java должна быть установлена до установки Eclipse.

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

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

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

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

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

Наверх

MySQL

Установите 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.

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

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

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

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

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

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

Наверх

AbstractTableModel

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

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

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 columnNames; //Данные; private Vector> tableData; //Классы колонок; protected Vector vColClass;  public KModel() { super(); vColClass = new Vector();  vColClass.add(0, Integer.class); vColClass.add(1, String.class); columnNames = new Vector(); 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> tableData) { this.tableData = tableData; }  public Vector> getTableData() { return tableData; }  }

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

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

Наверх

Java + MySQL

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

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

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

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> getNomen(String query)     {     Vector> retVector = new Vector>();         try         {         Statement st = con.createStatement();             ResultSet rs = st.executeQuery(query);             ResultSetMetaData rsmd = rs.getMetaData();             int cols = rsmd.getColumnCount(); while (rs.next()) { Vector newRow = new Vector(); for (int i = 1; i

В методе 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, получаем:

Пример для MySQL успешно завершён. Скачать пример MySQLProject (8 Кб).

]]>

Наверх

&nbsp