Scala Anorm查询异常处理：用Try与match优雅捕获异常

没问题，我来给你一步步演示怎么用Scala的Try和模式匹配来优雅处理Anorm的数据库异常，直接上可运行的示例，看完你就懂了。

核心思路 #

原来的代码直接执行数据库操作，没有异常捕获，一旦出现数据库连接失败、SQL语法错误等情况会直接抛出异常。我们可以用Scala标准库的scala.util.Try来包裹整个数据库操作逻辑——它会自动把成功的结果包装成Success，把所有非致命异常包装成Failure，然后通过模式匹配match来分别处理两种情况，完全替代传统的try-catch，代码更简洁函数式。

完整可运行示例 #

假设你用的是Play框架的Database API（如果是其他连接池，替换成对应的获取连接方式即可），完整代码如下：

import scala.util.Try
import anorm._
import play.api.db.Database

// 假设你已经通过依赖注入或其他方式拿到了Database实例
val database: Database = ???

// 用Try包裹数据库查询操作
val queryResult: Try[Boolean] = Try {
  database.withConnection { implicit connection =>
    // 这里可以替换成你的实际SQL语句
    SQL("SELECT 1").execute()
  }
}

// 模式匹配处理成功/失败场景
queryResult match {
  case Success(isExecuted) =>
    if (isExecuted) {
      println("查询成功执行")
      // 如果是查询数据的场景，可以在这里解析结果集
      // 比如：SQL("SELECT name FROM users").as(SqlParser.str("name").*)
    } else {
      println("查询执行完成（通常针对INSERT/UPDATE/DELETE这类无返回结果的操作）")
    }

  case Failure(exception) =>
    // 针对不同异常类型做精细化处理
    exception match {
      case sqlEx: java.sql.SQLException =>
        println(s"SQL执行错误：${sqlEx.getMessage}")
        println(s"错误代码：${sqlEx.getErrorCode}")
        println(s"SQL状态码：${sqlEx.getSQLState}")
        // 这里可以添加日志上报、告警通知等逻辑

      case connEx: java.sql.SQLNonTransientConnectionException =>
        println(s"数据库连接失败：${connEx.getMessage}")
        // 比如这里可以触发重试逻辑，或者通知运维排查

      case otherEx: Exception =>
        println(s"未知异常：${otherEx.getMessage}")
        otherEx.printStackTrace()
    }
}

扩展：查询并返回实体列表 #

如果你的需求是查询并返回业务实体（比如用户列表），同样可以用这套逻辑，示例如下：

// 定义业务实体类
case class User(id: Long, name: String)

val usersResult: Try[List[User]] = Try {
  database.withConnection { implicit c =>
    SQL("SELECT id, name FROM users").as(
      // 定义Anorm的结果解析器
      SqlParser.long("id") ~ SqlParser.str("name") map {
        case id ~ name => User(id, name)
      } * // *表示解析所有行
    )
  }
}

// 处理结果
usersResult match {
  case Success(users) => println(s"成功获取${users.size}个用户：$users")
  case Failure(ex) => println(s"获取用户列表失败：${ex.getMessage}")
}

最佳实践小提示 #

• 把数据库操作封装成独立方法，返回Try[T]类型，这样上层代码可以统一处理异常，代码更复用
• 根据异常类型做差异化处理：比如连接异常可以重试，SQL语法错误可以记录详细日志方便排查
• 避免在Failure分支里直接打印堆栈，建议用日志框架（如Logback）记录，生产环境更规范

内容的提问来源于stack exchange，提问作者Rob