在Scala中,你可以使用JDBC(Java Database Connectivity)或者一些流行的Scala库(如Slick、Quill等)来管理SQL事务
build.sbt
文件中添加以下依赖:libraryDependencies ++= Seq(
"mysql" % "mysql-connector-java" % "8.0.26",
"com.zaxxer" % "HikariCP" % "4.0.3"
)
import com.zaxxer.hikari.{HikariConfig, HikariDataSource}
val config = new HikariConfig()
config.setJdbcUrl("jdbc:mysql://localhost:3306/your_database")
config.setUsername("your_username")
config.setPassword("your_password")
config.addDataSourceProperty("cachePrepStmts", "true")
config.addDataSourceProperty("prepStmtCacheSize", "250")
config.addDataSourceProperty("prepStmtCacheSqlLimit", "2048")
config.addDataSourceProperty("useServerPrepStmts", "true")
val dataSource = new HikariDataSource(config)
Connection => Unit
类型的参数,该参数表示在事务中执行的操作。import java.sql.Connection
def withTransaction[T](block: Connection => T): T = {
val connection = dataSource.getConnection()
try {
connection.setAutoCommit(false)
val result = block(connection)
connection.commit()
result
} catch {
case e: Exception =>
connection.rollback()
throw e
} finally {
connection.close()
}
}
withTransaction
函数执行事务。在事务中,你可以执行多个SQL语句,并在所有操作成功后提交事务。如果发生任何异常,事务将回滚。withTransaction { connection =>
val insertStatement = connection.prepareStatement("INSERT INTO users (name, age) VALUES (?, ?)")
insertStatement.setString(1, "John Doe")
insertStatement.setInt(2, 30)
insertStatement.executeUpdate()
val updateStatement = connection.prepareStatement("UPDATE users SET age = age + 1 WHERE name = ?")
updateStatement.setString(1, "John Doe")
updateStatement.executeUpdate()
}
这样,你就可以在Scala中使用JDBC管理SQL事务了。请注意,这只是一个简单的示例,实际项目中你可能需要根据需求进行调整。此外,你还可以考虑使用Scala库(如Slick、Quill等)来简化数据库操作和事务管理。