Предупреждение:
Вообще говоря, информация из статьи применима только для некоторых специфических случаев. Например, когда приложение работает внутри какого-то сегмента изолированной сети. А в общем случае посредник, коим является http-сервер, всё-таки нужен. Хотя бы потому, что при описанном методе логин/пароль доступа к базе зашиты в приложении и передаются по сети.

В Java (и Android соответственно) соединение с удалёнными БД происходит при помощи JDBC-драйверов. В моём конкретном случае сервер майкрософтовский, и для него существует два драйвера: от Microsoft и открытая альтернатива JTDS. Причём последний, по заверениям разработчиков, работает быстрее и стабильней официального. Вот его и будем использовать.

Грабли: Актуальная версия JTDS на дату написания поста — 1.3.1. Но начиная с версии 1.3.0 драйвер переписан для совместимости с Java 7, и в сети встречаются сообщения о проблеме работы этих версий в Android. Поэтому необходимо использовать последнюю стабильную версию ветки 1.2.* (1.2.8), которая для Java 6.

На SQL-сервере должна быть настроена работа через TCP/IP.

Получение данных


Данные запросов драйвер возвращает в интерфейсе ResultSet который похож на андроидный Cursor, но быстрого способа приведения ResultSet к курсору я не нашёл. Поэтому поступим по-другому, данные из ResultSet будут конвертироваться в массив JSONArray и возвращаться в основную логику приложения, откуда с ними можно будет делать что угодно.

Весь обмен данными, как потенциально продолжительную операцию, будем делать асинхронно. В итоге получается примерно такой симпатичный класс для запросов к MS SQL:

EDIT: Переписал закрытие Connection, Statement и ResultSet в примерах в соответствии с основами.

public final class AsyncRequest extends AsyncTask<String, Void, JSONArray> {
 final static String MSSQL_DB = "jdbc:jtds:sqlserver://<YOUR_DB_IP>:<YOUR_DB_PORT>:/<YOUR_DB_NAME>;"
 final static String MSSQL_LOGIN = "<YOUR_DB_LOGIN>";
 final static String MSSQL_PASS= "<YOUR_DB_PASS>";

 @Override
 protected JSONArray doInBackground(String... query) {
   JSONArray resultSet = new JSONArray();
   try {
     Class.forName("net.sourceforge.jtds.jdbc.Driver");
     Connection con = null;
     Statement st = null;
     ResultSet rs = null;
     try {
       con = DriverManager.getConnection(MSSQL_DB, MSSQL_LOGIN, MSSQL_PASS);
       if (con != null) {
         st = con.createStatement();
         rs = st.executeQuery(query[0]);
         if (rs != null) {
           int columnCount = rs.getMetaData().getColumnCount();
           // Сохранение данных в JSONArray
           while (rs.next()) {
             JSONObject rowObject = new JSONObject();
             for (int i = 1; i <= columnCount; i++) {
               rowObject.put(rs.getMetaData().getColumnName(i), (rs.getString(i) != null) ? rs.getString(i) : "");
             }
             resultSet.put(rowObject);
           }
         }
       }
     } catch (SQLException e) {
       e.printStackTrace();
     } catch (JSONException e) {
       e.printStackTrace();
     } finally {
       try {
         if (rs != null) rs.close();
         if (st != null) st.close();
         if (con != null) con.close();
       } catch (SQLException e) {
         throw new RuntimeException(e.getMessage());
       }
     }
   } catch (ClassNotFoundException e) {
     e.printStackTrace();
   }
   return resultSet;
 }

 @Override
 protected void onPostExecute(JSONArray result) {
    // TODO: вернуть результат
 }
}


На вход классу подаётся запрос, на выходе — готовый JSONArray, как если бы мы получали данные от веб-сервера. В отдельном потоке AsyncTask соединяется с сервером, получает данные в ResultSet и формирует из них JSON. Думаю, в целом код примитивен и в пояснениях не нуждается.

Для построения систем, работающих по подобному принципу, лучше передавать на вход не чистые select-запросы, а написать на сервере готовые T-SQL функции, передавая параметры к которым, можно получать нужные выборки.

Insert и Update. Передача данных на сервер


К сожалению, тут я не придумал ничего лучше, просто выполнение Insert-ов в транзакции. В прочем, метод отлично работает, вставка нескольких сотен записей занимает приемлемое время (около секунды на 100 строк, полей в реальном проекте больше, чем в приведённом примере).

EDIT: по совету eyeless_watcher использую метод addBatch() при заполнении PreparedStatement. Вот теперь вставка данных выполняется на самом деле быстро, в одной транзакции. Пример изменил.

public final class AsyncInsert extends AsyncTask<String, Void, JSONArray> {

 private static final String REMOTE_TABLE = "dbo.TableName";
 private static final String SQL = "INSERT into " + REMOTE_TABLE + "([" +
            ListItemScanned.BARCODE + "],[" + ListItemScanned.NR_ID + "],[" +
            ListItemScanned.DATE + "],[" + ListItemScanned.STATUS + "]) values(?,?,?,?)";

 private final List<ListItemScanned> mData;

 public AsyncInsert(List<ListItemScanned> data) {
   this.mData = data;
 }

 @Override
 protected JSONArray doInBackground(String... proc_params) {
   JSONArray resultSet = new JSONArray();
   try {
     Class.forName("net.sourceforge.jtds.jdbc.Driver");
     Connection con = null;
     PreparedStatement prepared = null;
     try {
       con = DriverManager.getConnection(MSSQL_DB, MSSQL_LOGIN, MSSQL_PASS);
       if (con != null) {
         prepared = con.prepareStatement(SQL);

         for (ListItemScanned item : mData) {
           prepared.setString(1, item.get(ListItemScanned.BARCODE));
           prepared.setString(2, item.get(ListItemScanned.NR_ID));
           prepared.setString(3, item.get(ListItemScanned.DATE));
           prepared.setString(4, item.get(ListItemScanned.STATUS));
           prepared.addBatch();
           resultSet.put(item.get(ListItemScanned.ID));
         }
         prepared.executeUpdate();
         return resultSet;
       }
     } catch (SQLException e) {
         e.printStackTrace();
     } finally {
        try {
           if (prepared != null) prepared.close();
           if (con != null) con.close();
        } catch (SQLException e) {
           throw new RuntimeException(e.getMessage());
        }
     }
   } catch (ClassNotFoundException e) {
       e.printStackTrace();
   }
  return resultSet;
  }

Для вставки нужных значений используется PreparedStatement. Нумерация полей в нём почему-то начинается с единицы (см. документацию). А в остальном — всё должно быть понятно. update можно реализовать схожим образом, аналогично используя executeUpdate.

Приведённый подход был использован мной в «боевом» приложении первый раз.
На практике оказалось, что он стабильно работает. Время соединения с БД иногда может занимать несколько секунд (подключаюсь по wi-fi, сервер общий на всё предприятие), но сами транзакции выполняются быстро.

http://habrahabr.ru/post/206790/

Вверх