我们在做信息系统的时候,都要访问数据库,我最近接手一个项目,项目组决定使用Java编写,我负责数据层的设计和编码,为了提高代码的重用性和提高项目的开发效率。我们开发了一个通用的数据库连接和完成基本操作的类库,个人认为这个类在做MIS系统时还是有一定的价值,所以总结出来,介绍给大家。
连接工厂,实现了DataSource接口
package skydev.modules.data; import java.sql.*; import javax.sql.DataSource; import java.io.PrintWriter; public class ConnectionFactory implements DataSource { private String userName; private String password; private String driverName; private String url; private java.sql.Connection connection;
/** * 根据设置的连接参数创建一个新的连接实例 * @return */ private Connection getNewConnection() { try { this.connection.close(); //试图关闭连接 } finally { this.connection = null; //释放连接 try { Class.forName(this.driverName); //加载驱动程序 //DriverManager.registerDriver(driver); try { this.connection = DriverManager.getConnection(this.url, this.userName, this.password); } catch (SQLException e) { throw e; } } finally { return this.connection; //返回新建立的连接 } } }
public String getUserName() { return userName; }
public void setUserName(String userName) { this.userName = userName; }
public String getPassword() { return password; }
public void setPassword(String password) { this.password = password; }
public String getDriverName() { return driverName; }
public void setDriverName(String driverName) { this.driverName = driverName; }
public String getUrl() { return url; }
public void setUrl(String url) { this.url = url; }
public java.sql.Connection getConnection() { if (connection != null) { try { if (connection.isClosed()) { connection = null; getNewConnection(); } } catch (SQLException ex) { } } if (connection == null) { //没有设置连接则创建一个连接 getNewConnection(); } return connection; }
public Connection getConnection(String userName, String password) throws SQLException { this.setUserName(userName); this.setPassword(password); return getConnection(); }
public PrintWriter getLogWriter() { return null; }
public void setLogWriter(PrintWriter printWriter) { }
public void setLoginTimeout(int int0) { }
public int getLoginTimeout() { return 0; } } |
实现连接SQLServer的连接工厂,这里因为我们的项目使用SQLServer2000所以只实现了SqlServerConnectionFactory。
package skydev.modules.data; public final class SqlServerConnectionFactory extends ConnectionFactory { private final String dbDriver ="com.microsoft.jdbc.sqlserver.SQLServerDriver"; private String host;//主机 private int port;//端口 private String databaseName;//Sql数据库名称
public SqlServerConnectionFactory() { super.setDriverName(dbDriver); }
/** * * @param host 数据库所在的主机名:如"localhost" * @param port SQL服务器运行的端口号,如果使用缺省值 1433,传入一个负数即可 * @param databaseName 数据库名称 * @param userName 用户名 * @param password 口令 */ public SqlServerConnectionFactory(String host, int port, String databaseName, String userName, String password) { this.setHost(host); this.setPort(port); this.setDatabaseName(databaseName); this.setUserName(userName); this.setPassword(password); init(); }
private void init() { super.setDriverName(dbDriver); super.setUrl("jdbc:microsoft:sqlserver://" + host.trim() + ":" + new Integer(port).toString() + ";DatabaseName=" + databaseName.trim()); //super.setUrl("jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=demo"); }
public void setHost(String host) { //处理主机名称 if ( (host == null) || (host.equals("")) || (host.equals(".")) || (host.equals("local"))) { host = "localhost"; } int index = host.indexOf("//", 0); if (index == 0) { host = host.substring(2); //去掉前面的"//" } index = host.indexOf("//", 0); if (index >= 0) { try { throw new Exception("SQL Server主机名参数错误!"); } catch (Exception ex) { } } this.host = host; }
public void setPort(int port) { /** * 缺省端口1433 */ if (port < 0) { port = 1433; } this.port = port; }
public void setDatabaseName(String databaseName) { this.databaseName = databaseName; } }
使用"sun.jdbc.odbc.JdbcOdbcDriver"连接数据库的连接工厂 package skydev.modules.data; public class JdbcOdbcConnectionFactory extends ConnectionFactory { private final static String driveName = "sun.jdbc.odbc.JdbcOdbcDriver"; private String odbcName;
public JdbcOdbcConnectionFactory() { super.setDriverName(driveName); }
/** *使用指定的Odbc数据源连接数据库服务器 * @param odbcName */ public JdbcOdbcConnectionFactory(String odbcName) { super.setDriverName(driveName); setOdbcName(odbcName); }
public void setOdbcName(String odbcName) { this.odbcName = odbcName; this.setUrl("jdbc:odbc:" + odbcName); } } |
数据基本操作类,使用连接工厂连接数据库。
package skydev.modules.data; import java.sql.*; import java.sql.PreparedStatement; import javax.sql.DataSource;
public abstract class DatabaseObject { protected Connection connection = null; protected ResultSet resultSet = null; protected ResultSetMetaData resultSetMetaData = null; private ConnectionFactory connectionFactory = null; private java.sql.Statement statement=null; private javax.sql.DataSource dataSource;//=new Statement();
public DatabaseObject(){ dataSource=null; connection=null; }
public DatabaseObject(ConnectionFactory connectionFactory) { this.setConnectionFactory(connectionFactory); this.dataSource=connectionFactory;//ConnectionFactory实现了DataSource接口 }
/** * 执行查询 * @param sql 要执行的Sql语句 * @return 返回查询的结果集 ,查询失败返回null */ public ResultSet getResultSet(String sql) { try { this.resultSet = statement.executeQuery(sql); //保留内部指针 } catch (SQLException e) { e.printStackTrace(); this.resultSet = null; } finally { return this.resultSet; } }
/** * 获取外部指定ResltSet的ResultSetMetaData数据 * @param resultSet 要获取的ResultSet * @return 失败返回null */ public ResultSetMetaData getResultSetMetaData(ResultSet resultSet) { ResultSetMetaData resultSetMetaData = null; try { resultSetMetaData = resultSet.getMetaData(); } catch (SQLException e) { e.printStackTrace(); resultSetMetaData = null; } finally { return resultSetMetaData; } }
/** * 获取最近一次设置或者返回的ResultSet的ResultMetaData数据, * 比方说调用了:getResultSet(sql)方法,然后调用getResultSetMetaData方法 * 可以获得相应的ResultSetMetaData数据。 * @return */ public ResultSetMetaData getResultSetMetaData() { return this.getResultSetMetaData(this.resultSet); }
/** * 执行存储过程 * @param spName 存储过程名称 * @return */ public ResultSet Execute(String spName) { //对此数据库执行一个 SQL 查询 ResultSet resultSet = null; try { // PreparedStatement stmt = (PreparedStatement) connection.createStatement(); resultSet = statement.executeQuery(spName); } catch (Exception e) { System.out.println("execute error" + e.getMessage()); } return resultSet; }
/** * 设置数据库连接工厂,对此类的所有操作之前,必须调用该方法, * 设置数据库连接工厂。 * @param connectionFactory 数据库连接工厂ConnectionFactory 类对象以及 * 派生类对象。 */ public void setConnectionFactory(ConnectionFactory connectionFactory) { this.connectionFactory = connectionFactory; connection = connectionFactory.getConnection(); try { statement = connection.createStatement(); } catch (SQLException ex) { System.err.println(ex); } }
public Connection getConnection() { return connection; }
public java.sql.Statement getStatement() { return statement; } public javax.sql.DataSource getDataSource() { return dataSource; } } |
具体项目的数据库访问基类
package skydev.modules.data; public class DbObject extends DatabaseObject { // private final static String driveName = "sun.jdbc.obdc.JdbcOdbcDriver"; public DbObject() { super(new SqlServerConnectionFactory("localhost", 1433, "TheSchool", "sa","")); }
public DbObject(ConnectionFactory connectionFactory) { super(connectionFactory); } } |
在项目中的数据库层中的数据库访问类都从DatabaseObject类派生,这样只需要在一个地方设置数据连接,其他地方都不需要涉及数据库访问的具体连接代码。
如:User类专门负责Users组的权限控制等,只需要简单的代码就可以连接并访问数据库了。这里具体实 现与此文章无关,只举一两个模块做例子。
public class User extends DbObject { public User() { //子类也可以覆盖基类的访问方式,在单机调式时有用。 // super(new SqlServerConnectionFactory("localhost", 1433, "TheSchool", "sa","")); super();//调用基类的数据库访问代码。 } /* 在做信息系统时为了提高客维护性,我们一般使用存储过程返回和修改数据,在数据库层代码不使用
Select语句直接检索数据,做到数据库层代码的最大的灵活性和可维护性。一旦发现需要修改数据库中的
代码,只需要修改村年初过程即可以。 下面介绍Java使用SqlServer StoreProcedure的方法。 存储过程的参数使用“?”代替,下面的代码有一定的代表性,存储过程有输入参数,输出参数。 存储过程的基本功能为:检测userID和encPassword是否和数据库存储的一致,返回UserID,如果不一
致返回-1。 */ //测试数据库中存储的已经加密的密码和用户传入的加密的密码是否一致。 public boolean testPassword(int userID, byte[] encPassword) { Connection con = this.getConnection(); CallableStatement cs = null; try { cs = con.prepareCall("{?=call sp_Accounts_TestPassword(?,?)}"); cs.setInt(2, userID); cs.setBytes(3, encPassword); cs.registerOutParameter(1, Types.INTEGER); //@UserID cs.execute(); if (cs.getInt(1) == 1) { //密码合格 return true; } else { return false; } } catch (SQLException ex) { return false; } catch (Exception e) { return false; } } } |
以上只是我在学习和工作中的一点体会,写出来的目的使为了和大家交流,错误之处希望大家提出宝贵的意见,以便把该模块的功能做得更完善一点。
分享到:
相关推荐
采用JAVA技术实现JAVA数据库系统的应用
1、使用Java控制台实现一个小型学生管理系统的菜单选择界面,效果如下:2、使用JDBC完成对用户输入的学生信息进行数据库保存操作。界面效果如下:3、使用JDBC完成对用户选择的学号的学生信息进行更新操作。若用户...
程序实现了使用Java语言编程实现对数据库的访问,所有的SQL操作均在自己建立的新库里进行,数据库建议选用学生课程数据库,可以选择进行创建、插入、查询、删除和更新等操作,其中查询操作可以按学号、姓名、专业...
本项目是一套基于Java swing和mysql实现的银行管理系统,主要针对计算机相关专业的正在做毕设的学生与需要项目实战练习的Java学习者。 包含:项目源码、项目文档、数据库脚本等,该项目附带全部源码可作为毕设使用。...
采用mysql数据库,jsp+servlet+javabean技术,案例能直接运行,希望对jsp学习有帮助。
该实践性环节对于巩固学生的数据库知识,系统地掌握数据库设计理论与应用,加强学生的实践动手能力和提高学生的综合开发经验十分重要和必要。 本课程分为系统需求分析与数据库设计、应用程序功能设计和系统集成调试...
(2)Java数据库应用系统的实现 3.基于JAVA、XML的异构数据库集成应用 四、异构数据库集成中间件系统的设计分析 1.系统设计目标 2.系统分析 (1)系统结构设计现状 (2)中间件技术的标准 (3)系统运作流程分析 3.系统...
利用Java开发数据库应用系统时,经常需要在用户界面上显示查询结果。由于SUN公司提供的JDK1.x开发工具包不是可视化的集成开发环境 (IDE),不能象Delphi、VB那样方便地把查询结果在DBGrid等表格中显示出来。因此,...
Java数据库编程实战项目-网上书店管理系统!使用了图形用户界面GUI技术,jdbc技术连接数据库。包含完整的项目搭建教程以及源码。使用到的开发工具有idea,MySQL,数据库图形界面工具navicat。实现了图书信息管理,...
这篇文章介绍嵌入式数据库产品SQLite 的技术特点,并着重讨论研究与Java语言之间的接口,并以实例说明如何使用JAVA 开发基于SQLite 的应用程序。 正文: 通常我们采用各种数据库产品来实现对数据的存储、检索等...
利用JDBC API,Java开发 人员可以在单一的标准化功能库中编码,生成独立于数据库管理系统(DBMS)的Java应用系统。JDBC以X/Open组织的标准定义SQL调用级接口(Call Level Interface,CLI)。X/Open组织的宗旨是提供基于...
输入并分类浏览参赛队信息,实际上这是一个数据库应用范例,成绩统计基本全是对数据库的各种操作,代码中增加了丰富的注释,便于Java学习者参考。 这是之前世界杯的Java成绩统计,非本届世界杯,不过若写同类程序...
jsp运动管理系统 是一套完善的WEB设计系统,对理解JSP java 编程开发语言有帮助,系统具有完整的源代码和数据库,系统主要采用B/S模式开发。 应用技术:java|jsp+mysql 开发工具:Myeclipse或Eclipse、jdk、tomcat...
Java EE开发期末课程设计图书管理系统源码+开发文档+数据库。系统用户分为:借阅者(包括学生、教师及其他用户)、管理员Java EE开发期末课程设计图书管理系统源码+开发文档+数据库。系统用户分为:借阅者(包括学生...
Java论坛管理系统主要是实现在网上进行交流和学习Java语言,本论坛提供用户注册、发帖和回帖等论坛的基本功能,划分J2SE、J2EE、J2ME和开发工具的使用等版块,使用合理的管理方法管理论坛,严格保证帖子质量,为Java...
电商应用-电商应用系统-电商应用系统源码-电商应用管理系统-电商应用管理系统java代码-电商应用系统设计与实现-基于springboot的电商应用系统-基于Web的电商应用系统设计与实现-电商应用网站-电商应用网站代码-电商...
里面包含了源码和课程设计报告,可供学习参考。高分课设。注意只是数据库源码。 一、课程设计目的及基本要求 数据库系统课程设计是为数据库原理及应用...4)完成数据库定义工作,实现系统数据的数据录入和数据处理。
前言:我们在学习了Java各种基础知识之后,最需要做的就是学会应用,开发一些项目把所学的知识应用起来,下面的这个《校园在线考试系统》实战项目就是比较好的练手教程。 业务描述:根据前面所做的需求分析及用户的...
本系统是Java和数据库结合体,实现了公交车的增删改查。还增加了管理员和用户的角色,分别可以以不同的身份进入系统。本程序使用的是黄冈市公交数据。其关键技术是连接数据库和数据库的相关操作select,delete,update...