Пример обновления данных большого объема
В этом примере приложения драйвера Microsoft JDBC Driver для SQL Server продемонстрировано обновление большого столбца в базе данных.
Файл кода для этого образца имеет имя UpdateLargeData.java и находится в следующей папке:
\<installation directory>\sqljdbc_<version>\<language>\samples\adaptive
Требования
Для запуска этого примера приложения вам потребуется доступ к образцу базы данных AdventureWorks2022. Необходимо также включить в параметр classpath путь к файлу sqljdbc4.jar. Если параметр classpath не включает путь к файлу sqljdbc4.jar, то образец приложения вызовет стандартное исключение «Класс не найден». См. сведения о том, как настроить classpath в руководстве по использованию драйвера JDBC Driver.
Примечание.
Драйвер Microsoft JDBC Driver для SQL Server предоставляет файлы библиотек классов sqljdbc.jar, sqljdbc4.jar, sqljdbc41.jar и sqljdbc42.jar, которые используются в зависимости от выбранных вами параметров среды выполнения Java (JRE). В этом образце используются методы isWrapperFor и unwrap, которые были введены в API-интерфейсе JDBC 4.0, для вызова методов буферизации ответов в зависимости от драйвера. Чтобы скомпилировать и выполнить этот образец, понадобится библиотека классов sqljdbc4.jar, которая обеспечивает работу JDBC 4.0. Для получения дополнительных сведений о том, какой JAR-файл выбрать, см. статью Требования к системе для драйвера JDBC.
Пример
В следующем примере пример кода делает подключение к базе данных AdventureWorks2022. При помощи образца кода создается объект инструкции и используется метод isWrapperFor, чтобы проверить, является ли объект инструкции оболочкой для указанного класса SQLServerStatement. Метод unwrap также используется для получения доступа к методам буферизации ответов в зависимости от драйвера.
Далее при помощи образца кода задается режим буферизации ответов "adaptive" при помощи метода setResponseBuffering класса SQLServerStatement и демонстрируется установка адаптивного режима буферизации.
Выполняется инструкция SQL, возвращаемые данные размещаются в обновляемый объект SQLServerResultSet.
Наконец, образец кода выполняет проход по строкам данных в результирующем наборе. При обнаружении пустой сводки документа используется комбинация методов updateString и updateRow для обновления строки данных и обратного ее сохранения в базе данных. Если данные уже имеются, для отображения некоторых из них используется метод getString.
По умолчанию драйвер использует режим adaptive.. Однако для однопроходных результирующих наборов и в случае, если данные в результирующем наборе превышают по объему доступную память приложения, приложение должно задать адаптивный режим буферизации более четко, вызвав метод setResponseBuffering класса SQLServerStatement.
import java.io.Reader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import com.microsoft.sqlserver.jdbc.SQLServerStatement;
public class UpdateLargeData {
public static void main(String[] args) {
// Create a variable for the connection string.
String connectionUrl = "jdbc:sqlserver://<server>:<port>;databaseName=AdventureWorks;user=<user>;password=<password>";
// Establish the connection.
try (Connection con = DriverManager.getConnection(connectionUrl); Statement stmt = con.createStatement();
Statement stmt1 = con.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_UPDATABLE);) {
createTable(stmt);
// Since the summaries could be large, we should make sure that
// the driver reads them incrementally from a database,
// even though a server cursor is used for the updatable result sets.
// The recommended way to access the Microsoft JDBC Driver for SQL Server
// specific methods is to use the JDBC 4.0 Wrapper functionality.
// The following code statement demonstrates how to use the
// Statement.isWrapperFor and Statement.unwrap methods
// to access the driver specific response buffering methods.
if (stmt.isWrapperFor(com.microsoft.sqlserver.jdbc.SQLServerStatement.class)) {
SQLServerStatement SQLstmt = stmt.unwrap(com.microsoft.sqlserver.jdbc.SQLServerStatement.class);
SQLstmt.setResponseBuffering("adaptive");
System.out.println("Response buffering mode has been set to " + SQLstmt.getResponseBuffering());
}
// Select all of the document summaries.
try (ResultSet rs = stmt1.executeQuery("SELECT Title, DocumentSummary FROM Document_JDBC_Sample")) {
// Update each document summary.
while (rs.next()) {
// Retrieve the original document summary.
try (Reader reader = rs.getCharacterStream("DocumentSummary")) {
if (reader == null) {
// Update the document summary.
System.out.println("Updating " + rs.getString("Title"));
rs.updateString("DocumentSummary", "Work in progress");
rs.updateRow();
}
}
}
}
}
// Handle any errors that may have occurred.
catch (Exception e) {
e.printStackTrace();
}
}
private static void createTable(Statement stmt) throws SQLException {
stmt.execute("if exists (select * from sys.objects where name = 'Document_JDBC_Sample')"
+ "drop table Document_JDBC_Sample");
String sql = "CREATE TABLE Document_JDBC_Sample (" + "[DocumentID] [int] NOT NULL identity,"
+ "[Title] [char](50) NOT NULL," + "[DocumentSummary] [varchar](max) NULL)";
stmt.execute(sql);
sql = "INSERT Document_JDBC_Sample VALUES ('title1','summary1') ";
stmt.execute(sql);
sql = "INSERT Document_JDBC_Sample (title) VALUES ('title2') ";
stmt.execute(sql);
sql = "INSERT Document_JDBC_Sample (title) VALUES ('title3') ";
stmt.execute(sql);
sql = "INSERT Document_JDBC_Sample VALUES ('title4','summary3') ";
stmt.execute(sql);
}
}