groovy语法

import java.util.ArrayList;

import java.util.Collection;

import java.util.Iterator;

public class JavaIteratorExample {

  public static void main(String[] args) {

     Collection coll = new ArrayList();

     coll.add("JMS");

     coll.add("EJB");

     coll.add("JMX");

     for(Iterator iter = coll.iterator(); iter.hasNext();){

        System.out.println(iter.next());

     }

  }

}

class IteratorExample1{

   static void main(args) {

     coll = ["JMS","EJB","JMX"]

     coll.each{ item | println item }

   }

}

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

public class JDBCExample1 {

  public static void main(String[] args) {

    Connection con = null;

    Statement stmt = null;

    ResultSet rs = null;

    try{

      Class.forName("org.gjt.mm.mysql.Driver");

      con = DriverManager.getConnection("jdbc:mysql://localhost:3306/words","words","words");

      stmt = con.createStatement();

      rs = stmt.executeQuery("select * from word");

      while (rs.next()) {

        System.out.println("word id: " + rs.getLong(1) +

            " spelling: " + rs.getString(2) +

            " part of speech: " + rs.getString(3));

      }

    }catch(SQLException e){

      e.printStackTrace();

    }catch(ClassNotFoundException e){

      e.printStackTrace();

    }finally{

      try{rs.close();}catch(Exception e){}

      try{stmt.close();}catch(Exception e){}

      try{con.close();}catch(Exception e){}

   }

  }

}

import groovy.sql.Sql

class GroovySqlExample1{

  static void main(args) {

    sql = Sql.newInstance("jdbc:mysql://localhost:3306/words","org.gjt.mm.mysql.Driver")

    sql.eachRow("select * from word"){ println it.spelling +  " ${it.part_of_speech}"}

  }

}

 wid = 999

 spelling = "Nefarious"

 pospeech = "Adjective"

 sql.execute("insert into word (word_id,spelling,part_of_speech) 

   values (${wid},${spelling},${pospeech})")

val = sql.execute("select * from word where word_id = ?",[5])

 nid = 5

 spelling = "Nefarious"

 sql.executeUpdate("update word set word_id = ? where spelling = ?",[nid,spelling])

 sql.execute("delete from word where word_id = ?",51); font-family:Arial; font-size:14px; line-height:26px"> 
 
  简化数据操纵
 任何想简化 JDBC 编程的 API 或工具最好有一些好的数据操纵特性，在这一节中，我要向您再介绍三个。
 数据集(DataSet)
 构建于 GroovySql 简单性的基础之上，GroovySql 支持?DataSet?类型的概念，这基本上是数据库表的对象表示。使用?DataSet?，您可以在行中遍历，也可以添加新行。实际上，用数据集是方便地表示表格的公共数据集合的方式。
 但是，目前 GroovySql?DataSet?类型的不足之处是它们没有代表关系；它们只是与数据库表的一对一映射。在清单 10 中，我创建了一个来自?word?表的?DataSet?。
 
清单 10. 用 GroovySql 创建数据集

import groovy.sql.Sql

class GroovyDatasetsExample1{

  static void main(args) {

    sql = Sql.newInstance("jdbc:mysql://localhost:3306/words","org.gjt.mm.mysql.Driver")

    words = sql.dataSet("word")

    words.each{ word |

     println word.word_id + " " + word.spelling

    }

    words.add(word_id:"9999",spelling:"clerisy",part_of_speech:"Noun")

  }

}

 
   
 您可以看到，GroovySql 的?DataSet?类型可以容易地用?each?方法对表的内容进行遍历，容易地用?add?方法添加新行，?add?方法接受一个?map?表示需要的数据。
 
 
 使用存储过程和负索引
 
 
 存储过程调用和负索引（negative indexing）可能是数据操纵的重要方面。GroovySql 使存储过程调用简单得就像在?Sql?类上使用?call?方法一样。对于负索引， GroovySql 提供了自己增强的?ResultSet?类型，它工作起来非常像 Groovy 中的?collections?。例如，如果您想获取结果集中的最后一个项目，您可以像清单 11 所示的那样做：
 
 
 
清单 11. 用 GroovySql 进行负索引
 
 

 sql.eachRow("select * from word"){ grs |

   println "-1  = " + grs.getAt(-1) //prints spelling

   println "2  = " + grs.getAt(2) //prints spelling

 }

 
   
 您在清单 11 中可以看到，提取结果集的最后一个元素非常容易，只要用 -1 作索引就可以。如果想试试，我也可以用索引 2 访问同一元素。
 
 
 这些例子非常简单，但是它们能够让您很好地感觉到 GroovySql 的威力。我现在要用一个演示目前讨论的所有特性的实际例子来结束本月的课程。
 
 
 编写一个简单的报告应用程序
 
 
 报告应用程序通常要从数据库拖出信息。在典型的业务环境中，可能会要求您编写一个报告应用程序，通知销售团队当前的 Web 销售情况，或者让开发团队对系统某些方面（例如系统的数据库）的性能进行日常检测。
 
 
 为 了继续这个简单的例子，假设您刚刚部署了一个企业范围的 Web 应用程序。当然，因为您在编写代码时还（用 Groovy）编写了充足的单元测试，所以它运行得毫无问题；但是您还是需要生成有关数据库状态的报告，以便调优。您想知道客户是如何使用应用程序的，这 样才能发现性能问题并解决问题。
 
 
 通常，时间约束限制了您在这类应用程序中能够使用的提示信息的数量。但是您新得到的 GroovySql 知识可以让您轻而易举地完成这个应用程序，从而有时间添加更多您想要的特性。
 
 
 细节
 
 
 在这个例子中，您的目标数据库是 MySQL，它恰好支持用查询发现状态信息这一概念。以下是您有兴趣的状态信息：
 
 

运行时间。
 
  
处理的全部查询数量。
 
  
特定查询的比例，例如?insert?、?update?和?select?。
 
 
 用 GroovySql 从 MySQL 数据库得到这个信息太容易了。由于您正在为开发团队构建状态信息，所以您可能只是从一个简单的命令行报告开始，但是您可以在后面的迭代中把报告放在 Web 上。这个报告例子的用例看起来可能像这样：
 
 


1.
 
    
连接到我们的应用程序的活动数据库。
 
   

2.
 
    
发布?show status?查询并捕获：
 
   

?
 
    
a. 运行时间
 
   

?
 
    
b. 全部查询数
 
   

?
 
    
c. 全部?insert?数
 
   

?
 
    
d. 全部?update?数
 
   

?
 
    
e. 全部?select?数
 
   

3.
 
    
使用这些数据点，计算：
 
   

?
 
    
a. 每分钟查询数
 
   

?
 
    
b. 全部?insert?查询百分比
 
   

?
 
    
c. 全部?update?查询百分比
 
   

?
 
    
d. 全部?select?查询百分比
 
   

 在清单 12 中，您可以看到最终结果：一个将会报告所需数据库统计信息的应用程序。代码开始的几行获得到生产数据库的连接，接着是一系列?show status?查询，让您计算每分钟的查询数，并按类型把它们分开。请注意像uptime?这样的变量如何在定义的时候就创建。
 
 
 
清单 12. 用 GroovySql 进行数据库状态报告
 
 

import groovy.sql.Sql

class DBStatusReport{

  static void main(args) {

     sql = Sql.newInstance("jdbc:mysql://yourserver.anywhere/tiger","scott","tiger","org.gjt.mm.mysql.Driver")

     sql.eachRow("show status"){ status |

        if(status.variable_name == "Uptime"){

           uptime =  status[1]

        }else if (status.variable_name == "Questions"){

           questions =  status[1]

        }

     }

     println "Uptime for Database: " + uptime

     println "Number of Queries: " + questions

     println "Queries per Minute = " + Integer.valueOf(questions) / Integer.valueOf(uptime)

     sql.eachRow("show status like 'Com_%'"){ status |

        if(status.variable_name == "Com_insert"){

           insertnum =  Integer.valueOf(status[1])

        }else if (status.variable_name == "Com_select"){

           selectnum =  Integer.valueOf(status[1])

        }else if (status.variable_name == "Com_update"){

           updatenum =  Integer.valueOf(status[1])

       }

    }

    println "% Queries Inserts = " + 100 * (insertnum / Integer.valueOf(uptime))

    println "% Queries Selects = " + 100 * (selectnum / Integer.valueOf(uptime))

    println "% Queries Updates = " + 100 * (updatenum / Integer.valueOf(uptime))

    }

}

 
   
 ================================ ? 有关firstRow===========================
 
 
?/*根据基站信息 从基站-经纬信息表中查道对应的经纬度*/
? ? def findLngAndLatByCellInfo(mcc,mnc,lac,ci) {
? ? ? ? String signPOSMoveByLogStr = """
? ? ? ? ? ? select ?LNG,LAT
? ? ? ? ? ? from CELL_LNG_LAT cell2LngLat
? ? ? ? ? ? where ? cell2LngLat.mcc = '${mcc}' ?and
? ? ? ? ? ? ? ? ? ? cell2LngLat.mnc = '${mnc}' ?and
? ? ? ? ? ? ? ? ? ? cell2LngLat.lac = '${lac}' ?and
? ? ? ? ? ? ? ? ? ? cell2LngLat.ci ?= '${ci}'
? ? ? ? ?"""
? ? ? ? db.firstRow(signPOSMoveByLogStr);
? ? }
 
 
?def list = Commons.getDao().findLngAndLatByCellInfo? ? ? ? if(list!=null){//如果存在则从缓存表中去取
? ? ? ? ? ? lng = list.LNG;
? ? ? ? ? ? lat = list.LAT;
? ? ? ? }
 
 
主要注意这里的写法：
 
 
判断有没有值用null来比较
 
 
直接返回对象，点出来列就可以了，
 
 

        
            

        	



                        
（编辑：李大同）
【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!