import java.sql.Connection
import java.sql.DriverManager
import java.sql.PreparedStatement
import java.sql.ResultSet
import java.sql.SQLExceptionpublic class BaseDao {
private final String DRIVER = "org.h2.Driver"
private final String URL = "jdbc:h2:~/test"
private final String USER = "sa"
private final String PASS = ""
protected Connection conn = null// 数据库连接对象
@SuppressWarnings("unused")
protected PreparedStatement ps = null// 数据库执行对象
@SuppressWarnings("unused")
protected ResultSet rs = null// 数据库临时结果集 /**
* 获取数据库连接Connection对象
*
* @return
*/
@SuppressWarnings("unused")
protected Connection getConn() {
try {
Class.forName(DRIVER)
conn = DriverManager.getConnection(URL, USER, PASS)
if (conn != null)
return conn
} catch (Exception e) {
e.printStackTrace()
}
return null
} /**
* 关闭动态连接
*
* @param conn
* @param ps
*/
@SuppressWarnings("unused")
protected void closeLink(Connection conn, PreparedStatement ps) {
if (conn != null)
try {
conn.close()
} catch (SQLException e) {
e.printStackTrace()
}
if (ps != null)
try {
ps.close()
} catch (SQLException e) {
e.printStackTrace()
}
} /**
* 关闭动态连接(重载方法)
*
* @param conn
* @param ps
* @param rs
*/
@SuppressWarnings("unused")
protected void closeLink(Connection conn, PreparedStatement ps, ResultSet rs) {
if (conn != null)
try {
conn.close()
} catch (SQLException e) {
e.printStackTrace()
}
if (ps != null)
try {
ps.close()
} catch (SQLException e) {
e.printStackTrace()
}
if (rs != null)
try {
rs.close()
} catch (SQLException e) {
e.printStackTrace()
}
} // protected boolean insertDelete(String sql) {
// try {
// ps = this.getConn().prepareStatement(sql)
// if (ps != null)
// return ps.execute()
// } catch (SQLException e) {
// e.printStackTrace()
// } finally {
// this.closeLink(conn, ps)
// }
// return false
// }
//
// static public void main(String[] args) {
// BaseDao b = new BaseDao()
// System.out.println(b.insertDelete("create table AAA(Id int primary key,name varchar,sex varchar age int)"))
// }}
JDBC连接数据库•创建一个以JDBC连接数据库的程序,包含7个步骤:
1、加载JDBC驱动程序:
在连接数据库之前,首先要加载想要连接的数据库的驱动到JVM(Java虚拟机),
这通过java.lang.Class类的静态方法forName(String className)实现。
例如:
try{
//加载MySql的驱动类
Class.forName("com.mysql.jdbc.Driver")
}catch(ClassNotFoundException e){
System.out.println("找不到驱动程序类 ,加载驱动失败!")
e.printStackTrace()
}
成功加载后,会将Driver类的实例注册到DriverManager类中。
2、提供JDBC连接的URL
•连接URL定义了连接数据库时的协议、子协议、数据源标识。
•书写形式:协议:子协议:数据源标识
协议:在JDBC中总是以jdbc开始
子协议:是桥连接的驱动程序或是数据库管理系统名称。
数据源标识:标记找到数据库来源的地址与连接端口。
例如:(MySql的连接URL)
jdbc:mysql:
//localhost:3306/test?useUnicode=true&characterEncoding=gbk
useUnicode=true:表示使用Unicode字符集。如果characterEncoding设置为
gb2312或GBK,本参数必须设置为true 。characterEncoding=gbk:字符编码方式。
3、创建数据库的连接
•要连接数据库,需要向java.sql.DriverManager请求并获得Connection对象,
该对象就代表一个数据库的连接。
•使用DriverManager的getConnectin(String url , String username ,
String password )方法传入指定的欲连接的数据库的路径、数据库的用户名和
密码来获得。
例如:
//连接MySql数据库,用户名和密码都是root
String url = "jdbc:mysql://localhost:3306/test"
String username = "root"
String password = "root"
try{
Connection con =
DriverManager.getConnection(url , username , password )
}catch(SQLException se){
System.out.println("数据库连接失败!")
se.printStackTrace()
}
4、创建一个Statement
•要执行SQL语句,必须获得java.sql.Statement实例,Statement实例分为以下3
种类型:
1、执行静态SQL语句。通常通过Statement实例实现。
2、执行动态SQL语句。通常通过PreparedStatement实例实现。
3、执行数据库存储过程。通常通过CallableStatement实例实现。
具体的实现方式:
Statement stmt = con.createStatement()
PreparedStatement pstmt = con.prepareStatement(sql)
CallableStatement cstmt =
con.prepareCall("{CALL demoSp(? , ?)}")
就是JPA是吧,你要在数据库里新建一个数据库,然后在属性文件里配置连接参数,前期工作做好了,这里我贴出我以前项目代码给你看,服务器一运行就会自动创建表的.//////////////////////////////////////////////////////////////////////////
//
// Copyright 2010 Ningbo Safe Software Co.Ltd, All Right reserved.
//
//////////////////////////////////////////////////////////////////////////
package cn.credit.bean.information.cases
import java.io.Serializable
import java.util.Date
import javax.persistence.Column
import javax.persistence.Entity
import javax.persistence.Id
import javax.persistence.Table
import javax.persistence.Temporal
import javax.persistence.TemporalType
//************************************************************************
/**
* 系统名 : 信用物流系统平台 模块名 : 资讯系统 功能名 : 成功案例
*
* @author meiwx
* @version 1.0 Aug 13, 2010 作成
*
*/
// ************************************************************************
@Entity
@Table(name = "TAB_CASES")
public class Cases implements Serializable {
private static final long serialVersionUID = 1L
/* 审核员 */
private String assessor
/* 状态 */
private String status
/* 编码 */
private String id
/* 标题 */
private String title
/* 内容 */
private String content
/* 分类 */
private String sort
/* 作者 */
private String author
/* 删除区分 */
private char del_flg
/* 登录时间 */
private Date insert_time
/* 更新时间 */
private Date update_time
/* 录入员 */
private String update_user
/* 发布时间 */
private Date issue_time
/**
*
*
* @return
*/
@Temporal(TemporalType.TIMESTAMP)
@Column(name = "ISSUE_TIME", length = 20)
public Date getIssue_time() {
return issue_time
}
public void setIssue_time(Date issue_time) {
this.issue_time = issue_time
}
/**
*
* @return String
*/
@Id
@Column(name = "ID", length = 10, nullable = false)
public String getId() {
return id
}
/**
*
* @param id
*/
public void setId(String id) {
this.id = id
}
/**
*
* @return
*/
@Column(name = "STATUS", length = 1, nullable = false)
public String getStatus() {
return status
}
/**
*
* @return
*/
@Column(name = "TITLE", length = 20)
public String getTitle() {
return title
}
/**
*
* @param title
*/
public void setTitle(String title) {
this.title = title
}
/**
*
* @return
*/
@Column(name = "CONTENT", length = 21000)
public String getContent() {
return content
}
/**
*
* @param content
*/
public void setContent(String content) {
this.content = content
}
/**
*
* @return
*/
@Column(name = "SORT", nullable = false, length = 1)
public String getSort() {
return sort
}
/**
*
* @param sort
*/
public void setSort(String sort) {
this.sort = sort
}
/**
*
* @return String
*/
@Column(name = "AUTHOR", length = 10)
public String getAuthor() {
return author
}
/**
*
*/
@Column(name = "ASSESSOR")
public String getAssessor() {
return assessor
}
public void setAssessor(String assessor) {
this.assessor = assessor
}
public void setStatus(String status) {
this.status = status
}
/**
*
* @param author
*/
public void setAuthor(String author) {
this.author = author
}
/**
*
* @return
*/
@Column(name = "DEL_FLG", length = 1)
public char getDel_flg() {
return del_flg
}
public void setDel_flg(char del_flg) {
this.del_flg = del_flg
}
/**
*
* @return
*/
@Temporal(TemporalType.TIMESTAMP)
@Column(name = "INSERT_TIME", nullable = false)
public Date getInsert_time() {
return insert_time
}
/**
*
* @param insert_time
*/
public void setInsert_time(Date insert_time) {
this.insert_time = insert_time
}
/**
*
* @return
*/
@Temporal(TemporalType.TIMESTAMP)
@Column(name = "UPDATE_TIME", nullable = false)
public Date getUpdate_time() {
return update_time
}
/**
*
* @param update_time
*/
public void setUpdate_time(Date update_time) {
this.update_time = update_time
}
@Column(name = "UPDATE_USER", nullable = false)
public String getUpdate_user() {
return update_user
}
public void setUpdate_user(String update_user) {
this.update_user = update_user
}
}
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)