Groovy-16.数据库

悠扬前奏

发布于 2019-05-30 20:19:46

3930

发布于 2019-05-30 20:19:46

文章被收录于专栏：悠扬前奏的博客悠扬前奏的博客

Groovy中的Groovy-sql API支持各种各样的数据库，包括：

HSQLDB
Oracle
SQL Server
MySQL
MongoDB

jar包

以MySql为例，需要下载的jar包为：

mysql-connector-java-5.1.38-bin

连接

以下代码连接了一个

本地
接口为3306
库名为TESTDB
连接名为testuser
密码为test123
驱动为com.mysql.jdbc.Driver

的数据库

import java.sql.*; 
import groovy.sql.Sql 

class Example {
   static void main(String[] args) {
      // Creating a connection to the database
      def sql = Sql.newInstance('jdbc:mysql://localhost:3306/TESTDB', 
         'testuser', 'test123', 'com.mysql.jdbc.Driver')
            
      // Executing the query SELECT VERSION which gets the version of the database
      // Also using the eachROW method to fetch the result from the database
   
      sql.eachRow('SELECT VERSION()'){ row ->
         println row[0]
      }
        
      sql.close()  
   } 
}

建表

写好sql的字符串。以sql实例的execute方法执行即可。

import java.sql.*; 
import groovy.sql.Sql 

class Example { 
   static void main(String[] args) {
      // Creating a connection to the database
      def sql = Sql.newInstance('jdbc:mysql://localhost:3306/TESTDB', 'testuser',  
         'test123', 'com.mysql.jdbc.Driver')
            
      def sqlstr = """CREATE TABLE EMPLOYEE ( 
         FIRST_NAME CHAR(20) NOT NULL,
         LAST_NAME CHAR(20),
         AGE INT,
         SEX CHAR(1),
         INCOME FLOAT )""" 
                            
      sql.execute(sqlstr);
      sql.close() 
   } 
}

插入

$定义一个参数。在执行sql语句的时候替换为值：

import java.sql.*; 
import groovy.sql.Sql
 
class Example {
   static void main(String[] args) {
      // Creating a connection to the database
      def sql = Sql.newInstance('jdbc:mysql://localhost:3306/TESTDB', 'testuser', 
         'test123', 'com.mysql.jdbc.Driver')
            
      sql.connection.autoCommit = false  
      
      def firstname = "Mac"
      def lastname ="Mohan"
      def age = 20
      def sex = "M"
      def income = 2000  
        
      def sqlstr = "INSERT INTO EMPLOYEE(FIRST_NAME,LAST_NAME, AGE, SEX, 
         INCOME) VALUES " + "(${firstname}, ${lastname}, ${age}, ${sex}, ${income} )"
            
      try {
         sql.execute(sqlstr);
         sql.commit()
         println("Successfully committed") 
      } catch(Exception ex) {
         sql.rollback()
         println("Transaction rollback")
      }
        
      sql.close()
   }
}

读

使用SQL类的eachRow方法进行读操作。

eachRow(GString gString, Closure closure)

gString：待需要执行的SQL语句。
closure：闭包，用来处理来自读操作的数据行。

import java.sql.*; 
import groovy.sql.Sql
 
class Example {
   static void main(String[] args) {
      // Creating a connection to the database
      def sql = Sql.newInstance('jdbc:mysql://localhost:3306/TESTDB', 'testuser', 
         'test123', 'com.mysql.jdbc.Driver')  
            
      sql.eachRow('select * from employee') {
         tp -> 
         println([tp.FIRST_NAME,tp.LAST_NAME,tp.age,tp.sex,tp.INCOME])
      }  // [Mac, Mohan, 20, M, 2000.0]
      sql.close()
   } 
}