Scala的启发：代码本质与过度包装的平衡

本文来自王在祥先生的博客（blogspot），原标题为《重温 scala》。对于代码简洁化与可读性矛盾的解决，Scala语言无疑是一种启发。以下为原文：

创新互联是专业的路北网站建设公司，路北接单;提供成都网站设计、网站制作,网页设计,网站设计,建网站,PHP网站建设等专业做网站服务;采用PHP框架,可快速的进行路北网站开发网页制作和功能扩展;专业做搜索引擎喜爱的网站,专业的做网站团队,希望更多企业前来合作!

编辑推荐：Scala编程语言专题

#t#最近，在阅读项目组的代码时，再次陷入了苦思：基于Java、Hibernate的商业应用开发确实陷入到了一个很痛苦的境界，这个问题实际上正在进行开发的大部分开发人员都不会感觉到，因为大家都觉得这就是正常的程序员生活。再说，几乎所有的框架都在力捧Hibernate这样的ORM工具能够极大的简化程序的开发，要不，你去使用使用 JDBC试试。

在Java中基于JDBC编程，确实有些汇编语言的感觉，摘抄一份实际项目的代码：

 
 
 
      
  
  
  1. public void updateTerminalStatus(String timeout, String transtime) throws Exception {  
    2.   
  
  
  2.         //更新超时终端的状态值（9为超时）   
    3.   
  
  
  3.         String updateTerminal = "update T_Terminal set Status=9 "   
    4.   
  
  
  4.             + " where TerminalID in (select TerminalID from T_Terminal where TO_CHAR(latestDate, 'yyyymmddHH24miss')<=? and (status=0 or status=2) ) ";  
    5.   
  
  
  5.           
    6.   
  
  
  6.         //查询超时的终端信息，且该终端号在故障表中没有未处理的超时记录，（包含该终端号在故障表中没有超时记录的情况）。  
    7.   
  
  
  7.         String queryTimeOutTerm = "SELECT te.TerminalID FROM T_TERMINAL te WHERE te.status=9 ";  
    8.   
  
  
  8.         String queryTerm = "SELECT terminalid FROM T_TROUBLELOG tr " +  
    9.   
  
  
  9.                 " WHERE tr.DeviceID='COMMMODULE' AND tr.TroubleID='CommTimeOut' " +  
    10.   
  
  
  10.                 " AND tr.SolveDate IS NULL GROUP BY  terminalid ";  
    11.   
  
  
  11.           
    12.   
  
  
  12.         //向故障表中添加一条新的故障记录。  
    13.   
  
  
  13.         String insertTrouble = "insert into T_TroubleLog (LogID, TerminalID, DeviceID, TroubleID, HappenDate) " 
    14.   
  
  
  14.             + " values (?, ?, 'COMMMODULE', 'CommTimeOut', TO_DATE(?,'yyyymmddHH24miss')) ";  
    15.   
  
  
  15.           
    16.   
  
  
  16.         //更新故障表中的终端超时记录，该终端号的状态已经不超时,则超时故障处理完毕。  
    17.   
  
  
  17.         String updateTrouble = "UPDATE T_TROUBLELOG tl SET tl.SolveDate=TO_DATE(?,'yyyymmddHH24miss') " +  
    18.   
  
  
  18.                 " WHERE terminalid IN" +  
    19.   
  
  
  19.                 " (SELECT tm.terminalid FROM T_TERMINAL tm,T_TROUBLELOG tl " +  
    20.   
  
  
  20.                 " WHERE tm.Status != 9 AND tm.TerminalID=tl.TerminalID )" +  
    21.   
  
  
  21.                 " AND tl.DeviceID='COMMMODULE' AND tl.TroubleID='CommTimeOut' AND tl.SolveDate IS NULL ";  
    22.   
  
  
  22.           
    23.   
  
  
  23.         Connection conn = null;  
    24.   
  
  
  24.         PreparedStatement pstmt = null;  
    25.   
  
  
  25.         PreparedStatement pstmtInsert = null;  
    26.   
  
  
  26.         ResultSet rs = null;  
    27.   
  
  
  27.         List terlist = new ArrayList();  
    28.   
  
  
  28.         List noterlist = new ArrayList();  
    29.   
  
  
  29.         try {  
    30.   
  
  
  30.               
    31.   
  
  
  31.             conn = transDataSource.getConnection();  
    32.   
  
  
  32.             conn.setAutoCommit(false);  
    33.   
  
  
  33.  
    34.   
  
  
  34.             pstmt = conn.prepareStatement(updateTerminal);  
    35.   
  
  
  35.             pstmt.setString(1, timeout);  
    36.   
  
  
  36.             pstmt.executeUpdate();  
    37.   
  
  
  37.             pstmt.close();  
    38.   
  
  
  38.               
    39.   
  
  
  39.             pstmt = conn.prepareStatement(updateTrouble);  
    40.   
  
  
  40.             pstmt.setString(1, transtime);  
    41.   
  
  
  41.             pstmt.executeUpdate();  
    42.   
  
  
  42.             pstmt.close();  
    43.   
  
  
  43.             log.debug("更新完成");  
    44.   
  
  
  44.  
    45.   
  
  
  45.             //生成32位的随机ID，使用Hibernate中的UUID算法。  
    46.   
  
  
  46.             Properties props = new Properties();  
    47.   
  
  
  47.             props.setProperty("separator", "");  
    48.   
  
  
  48.             IdentifierGenerator gen = new UUIDHexGenerator();  
    49.   
  
  
  49.             ( (Configurable) gen ).configure(Hibernate.STRING, props, null);  
    50.   
  
  
  50.               
    51.   
  
  
  51.             pstmtInsert = conn.prepareStatement(insertTrouble);  
    52.   
  
  
  52.  
    53.   
  
  
  53.             pstmt = conn.prepareStatement(queryTerm);  
    54.   
  
  
  54.             rs = pstmt.executeQuery();  
    55.   
  
  
  55.             while(rs.next()){  
    56.   
  
  
  56.                 String termid = rs.getString(1);  
    57.   
  
  
  57.                 terlist.add(termid);  
    58.   
  
  
  58.             }  
    59.   
  
  
  59.             log.debug("查询终端号在故障表中没有未处理的超时记录完成");  
    60.   
  
  
  60.             rs.close();  
    61.   
  
  
  61.             rs = null;  
    62.   
  
  
  62.             pstmt.close();  
    63.   
  
  
  63.             pstmt = null;  
    64.   
  
  
  64.               
    65.   
  
  
  65.               
    66.   
  
  
  66.             pstmt = conn.prepareStatement(queryTimeOutTerm);  
    67.   
  
  
  67.             rs = pstmt.executeQuery();  
    68.   
  
  
  68.             while (rs.next()) {  
    69.   
  
  
  69.                 String term = rs.getString(1);  
    70.   
  
  
  70.                 noterlist.add(term);  
    71.   
  
  
  71.             }  
    72.   
  
  
  72.             log.debug("查询超时的终端信息完成" + noterlist.size());  
    73.   
  
  
  73.               
    74.   
  
  
  74.             for(int j = 0; j < noterlist.size(); j++){  
    75.   
  
  
  75.                 String terminalid = noterlist.get(j).toString();  
    76.   
  
  
  76.                 if(terlist.contains(terminalid)){  
    77.   
  
  
  77.                     continue;  
    78.   
  
  
  78.                 }  
    79.   
  
  
  79.                 pstmtInsert.setString(1, (String) gen.generate(null, null));  
    80.   
  
  
  80.                 pstmtInsert.setString(2, terminalid);  
    81.   
  
  
  81.                 pstmtInsert.setString(3, transtime);  
    82.   
  
  
  82.                 pstmtInsert.addBatch();  
    83.   
  
  
  83.             }  
    84.   
  
  
  84.             pstmtInsert.executeBatch();  
    85.   
  
  
  85.  
    86.   
  
  
  86.             conn.commit();  
    87.   
  
  
  87.             log.debug("向故障表中添加新的故障记录完成");  
    88.   
  
  
  88.               
    89.   
  
  
  89.         } catch (Exception ex) {  
    90.   
  
  
  90.             try{  
    91.   
  
  
  91.                 conn.rollback();  
    92.   
  
  
  92.             }catch (Exception e) {  
    93.   
  
  
  93.             }  
    94.   
  
  
  94.             throw ex;  
    95.   
  
  
  95.         } finally {  
    96.   
  
  
  96.             if (rs != null) {  
    97.   
  
  
  97.                 try {  
    98.   
  
  
  98.                     rs.close();  
    99.   
  
  
  99.                 } catch (Exception ex) {  
    100.   
  
  
  100.                 }  
    101.   
  
  
  101.             }  
    102.   
  
  
  102.             if (pstmt != null) {  
    103.   
  
  
  103.                 try {  
    104.   
  
  
  104.                     pstmt.close();  
    105.   
  
  
  105.                 } catch (Exception ex) {  
    106.   
  
  
  106.                 }  
    107.   
  
  
  107.             }  
    108.   
  
  
  108.             if (pstmtInsert != null) {  
    109.   
  
  
  109.                 try {  
    110.   
  
  
  110.                     pstmtInsert.close();  
    111.   
  
  
  111.                 } catch (Exception ex) {  
    112.   
  
  
  112.                 }  
    113.   
  
  
  113.             }  
    114.   
  
  
  114.             if (conn != null) {  
    115.   
  
  
  115.                 try {  
    116.   
  
  
  116.                     conn.close();  
    117.   
  
  
  117.                 } catch (Exception ex) {  
    118.   
  
  
  118.                 }  
    119.   
  
  
  119.             }  
    120.   
  
  
  120.         }  
    121.   
  
  
  121.     }  
    122.   
  
  
  122.  
    123.

这份代码长达120行，要去理解它还是得花一些时间的，如果使用 scala来写的话，可以怎么写呢？

 
 
 
      
  
  
  1. implicit val conn: Connection  = transDataSource.getConnection()  
    2.   
  
  
  2. transaction {  
    3.   
  
  
  3.  
    4.   
  
  
  4.     update("""update T_Terminal set Status=9 where TerminalID in   
    5.   
  
  
  5.         (select TerminalID from T_Terminal where TO_CHAR(latestDate, 'yyyymmddHH24miss')<= ? and (status=0 or status=2))  
    6.   
  
  
  6.         """, timeout);  
    7.   
  
  
  7.       
    8.   
  
  
  8.     update("""UPDATE T_TROUBLELOG tl SET tl.SolveDate=TO_DATE(?,'yyyymmddHH24miss') WHERE terminalid IN   
    9.   
  
  
  9.         (SELECT tm.terminalid FROM T_TERMINAL tm,T_TROUBLELOG tl  WHERE tm.Status != 9 AND tm.TerminalID=tl.TerminalID )   
    10.   
  
  
  10.         AND tl.DeviceID='COMMMODULE' AND tl.TroubleID='CommTimeOut' AND tl.SolveDate IS NULL  
    11.   
  
  
  11.         """, transtime);  
    12.   
  
  
  12.  
    13.   
  
  
  13.     val terlist: List[String] = List()  
    14.   
  
  
  14.     query("""SELECT terminalid FROM T_TROUBLELOG tr   
    15.   
  
  
  15.             WHERE tr.DeviceID='COMMMODULE' AND tr.TroubleID='CommTimeOut' AND tr.SolveDate IS NULL   
    16.   
  
  
  16.             GROUP BY  terminalid  
    17.   
  
  
  17.         """).foreach { (row) =>  
    18.   
  
  
  18.         terlist += row("terminalid")  
    19.   
  
  
  19.     }  
    20.   
  
  
  20.     log.debug("查询终端号在故障表中没有未处理的超时记录完成");  
    21.   
  
  
  21.  
    22.   
  
  
  22.     val noterlist: List[String] = List()  
    23.   
  
  
  23.     query("SELECT te.TerminalID FROM T_TERMINAL te WHERE te.status=9").foreach { (row)=>  
    24.   
  
  
  24.         noterlist += row("terminalid")  
    25.   
  
  
  25.     }  
    26.   
  
  
  26.     log.debug("查询超时的终端信息完成" + noterlist.size());  
    27.   
  
  
  27.  
    28.   
  
  
  28.     val psInsert = conn prepareStatement """insert into T_TroubleLog (LogID, TerminalID, DeviceID, TroubleID, HappenDate)   
    29.   
  
  
  29.         values (?, ?, 'COMMMODULE', 'CommTimeOut', TO_DATE(?,'yyyymmddHH24miss'))"""  
    30.   
  
  
  30.  
    31.   
  
  
  31.     for(val terminalId <- noterlist){  
    32.   
  
  
  32.         psInsert << uuid() << terminalid << transtime <  
  
  
  33.     }  
    34.   
  
  
  34.  
    35.   
  
  
  35. }  
    36.   
  
  
  36.  
    37.

这是一个直译的版本，代码函数为34行，瘦身到25%左右。不仅代码行数更短，而且新的代码的可读性也更高得多。

最近一直在思考，我们对JDBC是否做了过度的包装？包括事务处理，DAO等从EJB1.0时代产生的设计模式，到后续的O-R-M框架，看上去代码是越发简洁，实际上已经远远的远离代码的本质。这种基于Scala的JDBC简单封装，即便于我，也还远不如原始的4GL的简洁，但相比传统的jdbc或者后续的orm、spring+dao等等，则要简化得多。

scala到底能不能投入实际项目应用？开发人员的学习成本有多高？这个问题一直让我痛苦，最近，看到 dcaoyuan 先生的netbeans scala ide，让我重新点燃对scala的欲望，或许，在我们的平台中，接下来就可以尝试 scala了：至少在我看来，scala可以有效的消除我们目前代码中不必要的 DAO 模式以及复杂的事务处理模型等。如果能够在有限的范围内进行尝试，进而进行推广。或许能够在接下来能进一步的提高工作效率。

当前文章：Scala的启发：代码本质与过度包装的平衡
分享地址：http://www.csdahua.cn/qtweb/news3/552903.html

网站建设、网络推广公司-快上网，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 快上网

成都快上网为您推荐相关内容

网页设计公司知识

行业网站建设

成都营销型网站建设　　 　微信小程序　　 　网站制作　　 　成都温江机房　　 　艾名斯线缆　　 　成都网络推广公司　　 　香港虚拟主机腾讯云　　 　开元建筑　　 　3D立体画　　 　乐山做网站　　 　梓潼网站制作公司　　 　腾讯云香港虚拟主机　　 　青羊总部基地　　 　全网整合营销推广　　 　西部信息中心　　 　手机软件开发　　 　网络推广公司　　 　成都网站建设　　 　四川服务器托管　　 　域名注册