??孶縦 <%@ page imp">
当前位置：文档之家 › JDBC工具类

JDBC工具类

  • 格式：doc
  • 大小：68.50 KB
  • 文档页数：13

五、jsp连接Sybase数据库? 塪 三S testmysql.jsp如下： 齅?5<%@ page contentType="text/html;charset=gb2312"%> ? ?孶縦<%@ page import="java.sql.*"%> +肛Yl蠄 狒<html> 陫5 Ady?<body> ]Ci=?乷b?<%Class.forName("com.sybase.jdbc.SybDriver").newInstance(); R ?髰?String url =" jdbc:sybase:Tds:localhost:5007/tsdata"; P払? ?//tsdata为你的数据库名 .3dVvU粼Properties sysProps = System.getProperties(); ?) _昫龇SysProps.put("user","userid"); 轾HH. 芴竑SysProps.put("password","user_password"); `Y >矃jK1Connection conn= Dr iverManager.getConnection(url, SysProps); S-咢6s菘Statementstmt=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR _UPDATABLE); iE眹 %陀String sql="select * from test"; ?lt;拦 岛董ResultSet rs=stmt.executeQuery(sql); \鹍 #禺?:while(rs.next()) {%> +x?A???您的第一个字段内容为：<%=rs.getString(1)%> 奃h#}坜您的第二个字段内容为：<%=rs.getString(2)%> 敼蠵2Ⅱ?<%}%> R綮?铞邩?<%out.print("数据库操作成功，恭喜你");%> ??霬 ,<%rs.close(); 记?憍J髦?stmt.close(); 瞦样\芢?conn.close(); l洑`T ?%> hlb?誊?</body> 赡?肢J??</html> 夙蜵l卟UT?import java.util.*;import java.io.*;public class PropertyManager {private Properties properties = new Properties();File file;/** Creates a new instance of PropertyManager */public PropertyManager(String fileName) {String path = getClass().getResource("/").getPath();try{try{file = new File(path,fileName);}catch(Exception e){file = new File(path,"/"+fileName);}FileInputStream fis = new FileInputStream(file);properties.load(fis);fis.close();}catch(Exception e){e.printStackTrace();}}public String get(String key){return properties.getProperty(key.trim());}public String get(String key,String defaultValue){return properties.getProperty(key.trim(), defaultValue);}public void set(String key,String value){try{properties.setProperty(key,value);//new String(value.getBytes("UTF-8"), "UTF-8") }catch(Exception e){properties.setProperty(key, value);e.printStackTrace();}}synchronized public boolean store(){String path = getClass().getResource("/").getPath();boolean b = false;try{FileOutputStream fos = new FileOutputStream(file);properties.store(fos,"");fos.close();b = true;}catch(Exception e){b = false;e.printStackTrace();}file = null;return b;}public static void main(String arg[]){String path = new Object().getClass().getResource("/").getPath();System.out.println(path);}}import java.util.*;import java.io.*;public class PropertyManager {private Properties properties = new Properties();File file;/** Creates a new instance of PropertyManager */public PropertyManager(String fileName) {String path = getClass().getResource("/").getPath();try{try{file = new File(path,fileName);}catch(Exception e){file = new File(path,"/"+fileName);}FileInputStream fis = new FileInputStream(file);properties.load(fis);fis.close();}catch(Exception e){e.printStackTrace();}}public String get(String key){return properties.getProperty(key.trim());}public String get(String key,String defaultValue){return properties.getProperty(key.trim(), defaultValue);}public void set(String key,String value){try{properties.setProperty(key,value);//new String(value.getBytes("UTF-8"), "UTF-8") }catch(Exception e){properties.setProperty(key, value);e.printStackTrace();}}synchronized public boolean store(){String path = getClass().getResource("/").getPath();boolean b = false;try{FileOutputStream fos = new FileOutputStream(file);properties.store(fos,"");fos.close();b = true;}catch(Exception e){b = false;e.printStackTrace();}file = null;return b;}public static void main(String arg[]){String path = new Object().getClass().getResource("/").getPath();System.out.println(path);}}此类为读取*.properties的工具类Java代码public class DataBassInfo {private String driver;private String url;private String userName;private String password;/** Creates a new instance of DataBassInfo */public DataBassInfo() {PropertyManager pm = new PropertyManager("system.properties");driver = pm.get("DB_DRIVER");url = pm.get("DB_URL");userName = pm.get("DB_USERNAME");password = pm.get("DB_PASSWORD");}public String getDriver() {return driver;}public void setDriver(String driver) {this.driver = driver;}public String getUrl() {return url;}public void setUrl(String url) {this.url = url;}public String getUserName() {return userName;}public void setUserName(String userName) { erName = userName;}public String getPassword() {return password;}public void setPassword(String password) {this.password = password;}}public class DataBassInfo {private String driver;private String url;private String userName;private String password;/** Creates a new instance of DataBassInfo */public DataBassInfo() {PropertyManager pm = new PropertyManager("system.properties");driver = pm.get("DB_DRIVER");url = pm.get("DB_URL");userName = pm.get("DB_USERNAME");password = pm.get("DB_PASSWORD");}public String getDriver() {return driver;}public void setDriver(String driver) {this.driver = driver;}public String getUrl() {return url;}public void setUrl(String url) {this.url = url;}public String getUserName() {return userName;}public void setUserName(String userName) {erName = userName;}public String getPassword() {return password;}public void setPassword(String password) {this.password = password;}}此类为读取*.properties内容的bean类Java代码import java.sql.*;import java.util.ArrayList;public class ConnectionPool {protected static ConnectionPool connectionPool;protected String DBdriver;protected String DBurl;protected String DBuserName;protected String DBpassword;protected int maxConnection;protected int conNumber;protected ArrayList freeCon;/** Creates a new instance of ConnectionPool */protected ConnectionPool(DataBassInfo dbi){conNumber = 0;DBdriver = dbi.getDriver(); //"com.mysql.jdbc.Driver";DBurl = dbi.getUrl(); //"jdbc:mysql://localhost:3306/luru?autoReconnect=true&useUnicode=true&characterEncoding= UTF-8";DBuserName = dbi.getUserName(); //"";DBpassword = dbi.getPassword(); //"";freeCon = new ArrayList();try {Class.forName(DBdriver);} catch (ClassNotFoundException ex) {ex.printStackTrace();}System.out.println(DBurl);}public synchronized Connection getConnection(){Connection con = null;try {if(!freeCon.isEmpty()){con = (Connection)freeCon.get(0);freeCon.remove(0);}else{if(maxConnection == 0 || conNumber<maxConnection){con = DriverManager.getConnection(DBurl,DBuserName,DBpassword);conNumber++;}else{wait(2000);return getConnection();}}if(con!=null&&con.isClosed()){conNumber--;return getConnection();}} catch (Exception ex) {System.out.println("CONNECT IS NULL");con = null;ex.printStackTrace();}return con;}public synchronized void restore(Connection con){if(con!=null){try{freeCon.add(con);notifyAll();}catch (Exception ex) {con = null;ex.printStackTrace();}}}public synchronized void closeAll(){while(!freeCon.isEmpty()){Connection con = (Connection)freeCon.get(0);freeCon.remove(0);try {con.close();conNumber--;} catch (SQLException ex) {ex.printStackTrace();}}}public void setMaxConnection(int maxConnection){this.maxConnection = maxConnection;}public static ConnectionPool getInstance(){return getInstance(20);}public static synchronized ConnectionPool getInstance(int maxConnection){ if(connectionPool == null){DataBassInfo dbi = new DataBassInfo();connectionPool = new ConnectionPool(dbi);connectionPool.setMaxConnection(maxConnection);}return connectionPool;}protected void finalize() throws Throwable{closeAll();}}import java.sql.*;import java.util.ArrayList;public class ConnectionPool {protected static ConnectionPool connectionPool;protected String DBdriver;protected String DBurl;protected String DBuserName;protected String DBpassword;protected int maxConnection;protected int conNumber;protected ArrayList freeCon;/** Creates a new instance of ConnectionPool */protected ConnectionPool(DataBassInfo dbi){conNumber = 0;DBdriver = dbi.getDriver(); //"com.mysql.jdbc.Driver";DBurl = dbi.getUrl(); //"jdbc:mysql://localhost:3306/luru?autoReconnect=true&useUnicode=true&characterEncoding= UTF-8";DBuserName = dbi.getUserName(); //"";DBpassword = dbi.getPassword(); //"";freeCon = new ArrayList();try {Class.forName(DBdriver);} catch (ClassNotFoundException ex) {ex.printStackTrace();}System.out.println(DBurl);}public synchronized Connection getConnection(){Connection con = null;try {if(!freeCon.isEmpty()){con = (Connection)freeCon.get(0);freeCon.remove(0);}else{if(maxConnection == 0 || conNumber<maxConnection){con = DriverManager.getConnection(DBurl,DBuserName,DBpassword);conNumber++;}else{wait(2000);return getConnection();}}if(con!=null&&con.isClosed()){conNumber--;return getConnection();}} catch (Exception ex) {System.out.println("CONNECT IS NULL");con = null;ex.printStackTrace();}return con;}public synchronized void restore(Connection con){if(con!=null){try{freeCon.add(con);notifyAll();}catch (Exception ex) {con = null;ex.printStackTrace();}}}public synchronized void closeAll(){while(!freeCon.isEmpty()){Connection con = (Connection)freeCon.get(0);freeCon.remove(0);try {con.close();conNumber--;} catch (SQLException ex) {ex.printStackTrace();}}}public void setMaxConnection(int maxConnection){this.maxConnection = maxConnection;}public static ConnectionPool getInstance(){return getInstance(20);}public static synchronized ConnectionPool getInstance(int maxConnection){ if(connectionPool == null){DataBassInfo dbi = new DataBassInfo();connectionPool = new ConnectionPool(dbi);connectionPool.setMaxConnection(maxConnection);}return connectionPool;}protected void finalize() throws Throwable{closeAll();}}此类位处理连接的工具类system.properties中的配置DB_USERNAME=DB_DRIVER=DB_PASSWORD=DB_URL=四个属性对应DataBassInfo中的使用即为调用ConnectionPool .getInstance()方法得到连接，然后就可以操作了。

合集下载

JDBC知识点总结

JDBC知识点总结

JDBC知识点总结JDBC（Java Database Connectivity）是Java语言访问关系型数据库的标准接口。

它提供了一组方法和类，使得Java程序能够和数据库进行连接、查询和更新等操作。

下面是关于JDBC的知识点总结。

1.JDBC的工作机制JDBC通过驱动程序（Driver）将Java程序和数据库连接起来。

驱动程序的主要作用是提供与数据库通信的实现。

JDBC的工作机制可以分为以下几个步骤：- 加载驱动程序：使用Class.forName(方法加载驱动程序类。

- 建立连接：使用DriverManager.getConnection(方法建立与数据库的连接。

- 创建语句对象：使用连接对象的createStatement(方法或prepareStatement(方法创建Statement或PreparedStatement对象。

- 执行SQL语句：使用Statement或PreparedStatement对象的executeQuery(、executeUpdate(等方法执行SQL语句。

- 处理结果：对于查询操作，可以通过ResultSet对象获取结果集中的数据；对于更新操作，可以通过返回的整数值判断操作是否成功。

- 关闭连接：使用Connection对象的close(方法关闭连接。

2.JDBC的核心接口- Connection接口：表示数据库连接对象。

可以通过DriverManager.getConnection(方法获取Connection对象。

- Statement接口：用于执行静态SQL语句，不带参数。

- PreparedStatement接口：用于执行带有参数的SQL语句，可以提高SQL语句的效率和安全性。

- CallableStatement接口：用于执行存储过程。

- ResultSet接口：表示查询结果集。

可以通过Statement或PreparedStatement的executeQuery(方法获取ResultSet对象。

simplejdbcinsert类

simplejdbcinsert类

simplejdbcinsert类SimpleJdbcInsert类是一个用于简化JDBC插入操作的工具类。

它提供了一种简单的方法来创建插入语句，并自动处理SQL注入和参数绑定等问题。

一、类概述SimpleJdbcInsert类继承自JdbcTemplate类，它提供了一个简洁的接口，用于执行插入操作。

通过使用SimpleJdbcInsert类，开发人员可以轻松地编写插入语句，并自动处理数据库连接、参数绑定和事务管理等繁琐的工作。

二、使用方法要使用SimpleJdbcInsert类，首先需要将其添加到项目中。

通常，可以使用Maven或Gradle等构建工具来实现。

添加依赖后，即可在代码中实例化SimpleJdbcInsert对象，并使用其提供的方法来创建插入语句。

1. 添加依赖在Maven项目中，可以在pom.xml文件中添加以下依赖：```maven<dependency><groupId>com.example</groupId><artifactId>simplejdbc</artifactId><version>1.0.0</version></dependency>```2. 创建插入语句使用SimpleJdbcInsert类创建插入语句非常简单。

只需要将要插入的数据作为参数传递给构造函数，并指定要插入的表名即可。

例如：```javaSimpleJdbcInsert insert = newSimpleJdbcInsert(jdbcTemplate).addColumn("column1", "value1") .addColumn("column2", "value2").insertInto("tableName");```上述代码创建了一个插入语句，将要插入的值插入到"tableName"表中。

jdbctemplate 批量update用法

jdbctemplate 批量update用法

jdbctemplate 批量update用法=========在使用JDBC进行数据库操作时，有时候我们需要更新大量的数据。

JdbcTemplate是Spring框架中一个非常有用的工具类，它可以简化数据库操作，尤其在批量更新数据时。

本篇文章将详细介绍如何使用JdbcTemplate进行批量update操作。

一、JdbcTemplate简介---------JdbcTemplate是Spring框架提供的一个JDBC抽象类，它封装了JDBC的细节，使得开发者可以通过模板式的方法来执行SQL语句。

通过使用JdbcTemplate，我们可以方便地执行批量操作，减少数据库连接的开销，提高数据库操作的效率。

二、批量update用法---------1. 引入依赖-------首先，确保你的项目中引入了Spring框架和相关的JDBC依赖。

2. 创建数据源配置----------在Spring配置文件中，配置数据源的相关信息，包括连接URL、用户名、密码等。

------------------------使用JdbcTemplate进行批量update操作非常简单。

只需要在需要批量update的地方调用executeBatch()方法即可。

示例代码：```javaJdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);List<UpdateRowModel> updateModels = getUpdateModels(); // 假设有一个UpdateRowModel对象列表需要批量更新for (UpdateRowModel updateModel : updateModels) {jdbcTemplate.update("your_sql_statement", updateModel.getParams()); // 将需要更新的参数传递给SQL语句}jdbcTemplate.executeBatch(); // 执行批量更新操作```其中，UpdateRowModel是一个自定义类，用于封装需要更新的参数。

jdbctemplate调用返游标的存储过程

jdbctemplate调用返游标的存储过程

JdbcTemplate是Spring框架中用于简化数据库操作的一个工具类，通过JdbcTemplate可以方便地进行数据库操作，包括执行SQL语句、调用存储过程等。

在实际应用中，经常需要调用返回游标的存储过程，本文将详细介绍如何使用JdbcTemplate来调用返回游标的存储过程。

存储过程是在数据库中预先编译好的一组SQL语句，通过存储过程可以方便地实现复杂的业务逻辑。

有些存储过程会返回游标，用于返回查询结果集。

在使用JdbcTemplate调用返回游标的存储过程时，需要注意以下几点：1. 编写存储过程需要在数据库中编写一个返回游标的存储过程。

存储过程的语法和数据库的类型有关，这里以Oracle数据库为例，假设有一个名为“get_users”的存储过程，用于返回用户表中的所有用户信息。

```CREATE OR REPLACE PROCEDURE get_users (p_cursor OUTSYS_REFCURSOR) ASBEGINOPEN p_cursor FORSELECT * FROM users;END;```在这个存储过程中，定义了一个输出参数p_cursor，用于返回游标。

游标的类型为SYS_REFCURSOR，可以用于返回查询结果集。

2. 定义JdbcTemplate bean在Spring的配置文件中，需要定义一个JdbcTemplate的bean，并配置数据源等信息。

```<bean id="jdbcTemplate"class="org.springframework.jdbc.core.JdbcTemplate"><property name="dataSource" ref="dataSource"/></bean>```这里假设数据源的名称为dataSource，需要在配置文件中定义数据源的相关信息。