Java-соединения, связанные с безопасностью базы данных

Question

Я пишу сервлет, который обрабатывает каждый запрос, обращаясь и изменяя некоторые таблицы (таблицы) в базе данных. Я хочу, чтобы соединения с базой данных были потокобезопасными. Я не хочу использовать уже существующие библиотеки/рамки для этого (весна, спящий режим и т. Д.).

Я знаю, что могу использовать ThreadLocal Java для этого следующим образом:

public class DatabaseRegistry { //assume it's a singleton 


private Properties prop = new Properties(); 
    public static final ThreadLocal<Connection> threadConnection = new ThreadLocal<Connection>(); 

    private Connection connect() throws SQLException { 
     try { 
      // This will load the MySQL driver, each DB has its own driver 
      Class.forName("com.mysql.jdbc.Driver"); 
      // Setup the connection with the DB 
      Connection connection = DriverManager 
        .getConnection("jdbc:mysql://" + prop.getProperty("hostname") + "/" + prop.getProperty("database") + "?" 
          + "user=" + prop.getProperty("username") + "&password=" + prop.getProperty("password")); 
      return connection; 
     } catch (SQLException e) {   
      throw e; 
     } catch (ClassNotFoundException e) { 
      e.printStackTrace(); 
     } 

     return null; 

    } 

    public Connection getConnection() throws SQLException { 

     if(threadConnection.get() == null) { 
      Connection connection = connect(); 
      threadConnection.set(connection); 
      return threadConnection.get(); 
     } else 
      return threadConnection.get(); 
    } 

    private void freeConnection(Connection connection) throws SQLException { 
     connection.close(); 
     threadConnection.remove(); 
    } 
} 

Каждый раз, когда вы звоните GetConnection, новое соединение добавляется в ThreadLocal объект, а затем удаляется, когда вы освобождаете соединение() ,

Правильно ли это делается или должен ли DatabaseRegistry распространять класс ThreadLocal? Или есть еще лучший способ сделать это, чтобы все потоки соединений были безопасными?

Благодаря

Answer 1

Я не думаю, что создание соединений с базами данных потокобезопасными является обычной практикой. Обычно то, что вы хотите, или:

• Serialize доступ к некоторой части вашего сервлета, так что не более чем один сервлет выполнения кода в то время (бывший реализующий интерфейс SingleThreadModel).
• Блокировка конкретной таблицы/таблицы/строки, чтобы вы могли работать с определенными кортежами (путем изменения уровня изоляции базы данных).
• Использование оптимистической блокировки для обнаружения измененных строк в таблице (с использованием некоторого ссылочного атрибута таблицы, чтобы проверить, совпадает ли текущая версия с той, которая находится в таблице).

AFAIK, типичное использование ThreadLocal - это сохранение уникального соединения с базой данных для каждого потока, так что одно и то же соединение может использоваться различными способами в вашей бизнес-логике без необходимости передавать его как параметр каждый раз. Поскольку обычная реализация контейнера сервлетов использует поток для полного HTTP-запроса, тогда два разных запроса гарантируют использование двух разных соединений с базой данных.

Answer 2

Я не знаю, почему вы хотите, чтобы ваши соединения DB быть поточно. Большая часть времени установления соединения с базой данных является самой длинной частью транзакции. Обычно соединения повторно используются между запросами и пулами открытых подключений управляются (через фреймворки или, более типично, серверы приложений).

Если вы беспокоитесь о параллельных изменениях в одних и те же таблицы, вы можете захотеть взглянуть на синхронизированных методах: http://docs.oracle.com/javase/tutorial/essential/concurrency/syncmeth.html

Answer 3

Я знаю, что вы сказали, что не хотите использовать библиотеки, чтобы сделать это, но если вы сделаете это, вы будете лучше. Выберите стандартный пул соединений (C3P0, DBCP или что-то еще), и вы станете счастливее, чем если будете испечь свои собственные. Почему вы не можете использовать библиотеку для этого?