Java 实现Gbase数据库增删改查功能

Java 实现Gbase数据库增删改查功能

具体代码如下

主要： 要记得在官网下载驱动包gbase-connector-java-8.3-bin.jar

package com.advance.JDBC;

import org.apache.log4j.Logger;

import org.apache.storm.command.list;

import java.sql.;

import java.util.;

public class Connect_GBase {

private static Logger logger = Logger.getLogger(Connect_GBase.class);

//三大核心接口

private static Connection conn = null;

private static PreparedStatement pstmt = null;

private static ResultSet rs = null;

public static Connection connectGBase() {

//加载MySql的驱动类

try {

Class.forName(“com.gbase.jdbc.Driver”);

} catch (ClassNotFoundException e) {

logger.error(“找不到驱动程序类 ，加载驱动失败！”);

e.printStackTrace();

}

//URL

String url = “jdbc:gbase://10.136.1.215:5258/testdb?characterEncoding=utf8”;

//账号

String username = “root”;

//密码

String password = “gbase8a”;

try {

conn = DriverManager.getConnection(url,username,password);

} catch (SQLException e) {

logger.error(“数据库连接失败！”);

e.printStackTrace();

}

return conn;

}

//关闭数据库连接

public static void closeConnection(){

if(rs!=null){

try {

rs.close();

} catch (SQLException e) {

e.printStackTrace();

}

}

if(pstmt!=null){

try {

pstmt.close();

} catch (SQLException e) {

e.printStackTrace();

}

}

if(conn!=null){

try {

conn.close();

} catch (SQLException e) {

e.printStackTrace();

}

}

}

public static List resultSetToList(ResultSet rs,String columnName) throws java.sql.SQLException {

if (rs == null)

return Collections.EMPTY_LIST;

ResultSetMetaData md = rs.getMetaData(); //得到结果集(rs)的结构信息，比如字段数、字段名等

int columnCount = md.getColumnCount(); //返回此 ResultSet 对象中的列数

List list = new ArrayList();

// Map rowData;

// while (rs.next()) {

//

// rowData = new HashMap(columnCount);

// for (int i = 1; i <= columnCount; i++) {

// rowData.put(md.getColumnName(i), rs.getObject(i));

// System.out.println(rowData.get(“id”) + “" + rowData.get(“name”) + "” + rowData.get(“age”) );

// }

// if(columnName==null) {

// list.add(rowData);

// }else {

// list.add(rowData.get(columnName));

// }

// }

while (rs.next()) {

System.out.println(

rs.getString(“id”) + “_” + rs.getString(“name”));

}

return list;

}

public static ResultSet query(String sql) throws SQLException, ClassNotFoundException {

conn = connectGBase();

pstmt = conn.prepareStatement(sql);

rs = pstmt.executeQuery();

return rs;

}

public static void update(String sql,Object []values) throws SQLException, ClassNotFoundException {

//获取数据库链接

conn=connectGBase();

try {

//预编译

pstmt=conn.prepareStatement(sql);

//获取ParameterMetaData()对象

ParameterMetaData pmd=pstmt.getParameterMetaData();

//获取参数个数

int number=pmd.getParameterCount();

//循环设置参数值

for (int i = 1; i <=number; i++) {

pstmt.setObject(i, values[i-1]);

}

pstmt.executeUpdate();

System.out.println(“执行成功”);

} catch (SQLException e) {

e.printStackTrace();

}

}

public static void output(ResultSet rs) throws SQLException {

ResultSetMetaData md = rs.getMetaData(); //得到结果集(rs)的结构信息，比如字段数、字段名等

int columnCount = md.getColumnCount();

while(rs.next())

{

StringBuffer sb = new StringBuffer();

for (int i = 1; i <= columnCount; i++) {

sb.append(rs.getObject(i)+" ");

}

logger.debug(sb);

System.out.println(sb);

}

while (rs.next()) {

System.out.println(rs.getString(“name”));

}

}

public static void main(String[] args) throws SQLException, ClassNotFoundException {

//update(“update aa set name = ? where id = ?”,new Object[]{“7”,“1”});

// update("insert into COMPANY (id,name,age , address, salary) " +

// “values (?,?,?,?,?)”,new Object[]{“2”,“lisi”,“4”,“6”,“5”});

//update(“delete from aa where id = ?”,new Object[]{“5”});

ResultSet rs = query("select * from COMPANY ");

List<Map<String,Object>> result = resultSetToList(rs,“name”);

output(rs);

closeConnection();

}

// 建表语句：

// CREATE TABLE COMPANY(

// ID int ,

// NAME VARCHAR(40) NOT NULL,

// AGE INT NOT NULL,

// ADDRESS CHAR(50),

// SALARY DECIMAL(10,2)

//);

}