java程序 *** 作MySQL数据库

数据库内容

  java源代码 （代码实现的是查询成绩为 的人员信息 至于其他功能的 代码中有注释） 注意 在eclipse里运行程序的时候 要工程里插入jar包 否则运行异常！ import java sql *import java io *class database_manage {  public Connection conn = null public ResultSet rs = null private String DatabaseDriver = " mysql jdbc Driver" // DataSource 数据源名称DSN  private String DatabaseConnStr = "jdbc:mysql://localhost: /people_manage?useUnicode=true&characterEncoding=utf "  + " root root" public void setDatabaseDriver(String Driver) { this DatabaseDriver = Driver }  public String getDatabaseDriver() { return (this DatabaseDriver) }  public void setDatabaseConnStr(String ConnStr) { this DatabaseConnStr = ConnStr }  public String getDatabaseConnStr() { return (this DatabaseConnStr) }  public database_manage() {// 构造函数连接数据库 try {  Class forName(DatabaseDriver)} catch (java lang ClassNotFoundException e) {  System err println("加载驱动器有错误:" + e getMessage()) System out print("执行插入有错误:" + e getMessage())// 输出到客户端 }  }  public ResultSet query(String sql) {// 查询数据库 rs = nulltry {  conn = DriverManager   getConnection(  "jdbc:mysql://localhost: /people_manage?useUnicode=true&characterEncoding=utf "  "root" "root") Statement stmt = conn createStatement() rs = stmt executeQuery(sql)} catch (SQLException ex) {  System err println("执行查询有错误:" + ex getMessage()) System out print("执行查询有错误:" + ex getMessage())// 输出到客户端 }

return rs

 }  public int update_database(String sql) {// 更新或插入数据库 int num = try {  conn = DriverManager   getConnection(  "jdbc:mysql://localhost: /people_manage?useUnicode=true&characterEncoding=utf "  "root" "root") Statement stmt = conn createStatement() num = stmt executeUpdate(sql)} catch (SQLException ex) {  System err println("执行插入有错误:" + ex getMessage()) System out print("执行插入有错误:" + ex getMessage())// 输出到客户端 } 　CloseDataBase()return num }  public void CloseDataBase() {// 关闭数据库 try {  conn close()} catch (Exception end) {  System err println("执行关闭Connection对象有错误 " + end getMessage()) System out print("执行执行关闭Connection对象有错误 有错误:" + end getMessage())// 输出到客户端 }  } } class people {  private String uid private String name private String banji private int score public people() {  }  public people(String uid String name String banji) { this uid = uidthis name = namethis banji = banji }  public people(String uid String name String banji int score) { this uid = uidthis name = namethis banji = banjithis score = score }  public String getUid() { return uid }  public void setUid(String uid) { this uid = uid }  public String getName() { return name }  public void setName(String name) { this name = name }  public String getBanji() { return banji }  public void setBanji(String banji) { this banji = banji }  public int getScore() { return score }  public void setScore(int score) { this score = score } } public class manage {  private people[] people_array // 对象数组  public void add_people(String uid String name) { 　String sql = "insert people (uid name) values ( " + uid + " " + name + " )"// sql插入语句 // String sql = "insert people (uid name) values ( uid tom )"　database_manage db_obj = new database_manage()db_obj update_database(sql) }  public void update_people(String uid String name) { 　String sql = "update people set name= " + name + " where uid= " + uid + " "database_manage db_obj = new database_manage()db_obj update_database(sql) }  public void delete_people(String uid) { 　String sql = "delete from people  where uid= " + uid + " "　database_manage db_obj = new database_manage()　db_obj update_database(sql) }  public people query_people(String uid) { database_manage db_obj = new database_manage()// String adminid=nullString uid_new name banjiuid_new = nullname = nullbanji = nullString sql_query = "select * from people where uid= " + uid + " "　try {  ResultSet rs = db_obj query(sql_query) if (rs next()) { uid_new = rs getString("uid")name = rs getString("name")banji = rs getString("banji") } } catch (Exception e) {  e getMessage()} people new_people = new people(uid_new name banji)return new_people }  public people[] query_people_byscore(int score) { database_manage db_obj = new database_manage()String uid_new name banjiuid_new = nullname = nullbanji = nullint score_new =

String sql_query = "select * from people where score=" + score// sql查询语句

try {

ResultSet rs = db_obj query(sql_query)// 查询后 返回结果集

int num =

ResultSet rs_new = rs

while (rs_new next()) {// 统计结果集中学生个数

num++

}

// System out println(num)

people_array = new people[num]

int i =

rs beforeFirst()// 返回结果集的开始

while (rs next()) {

uid_new = rs getString("uid")

name = rs getString("name")

banji = rs getString("banji")

score_new = rs getInt("score")

people_array [i] = new people(uid_new name banji score_new)

i++

}

} catch (Exception e) {

e getMessage()

}

return people_array

}

public static void main(String args[]) {

/*

* people new_people=new people()

*

* manage mr=new manage()//mr add_people(" " "小明")插入一个学生的信息

*

* new_people=mr query_people(" ")//查询uid= 的学生信息 返回对象 System out

* println(""+new_people getName()+"　 "+new_people getBanji())

* mr update_people(" " "小王")更新一个学生的信息

*

* new_people=mr query_people(" ")//更新后查询

*

* System out println(""+new_people getName()+"　 "+new_people getBanji(

* ))

*/

manage mr = new manage()

// mr delete_people(" ")删除uid= 的学生信息

people[] people_array// 声明对象数组

people_array = mr query_people_byscore( )// 返回成绩为一百的学生类数组 后输出

int num =

num = people_array length

for (int i = i <numi++) {

System out println(people_array[i] getUid() + " "

+ people_array[i] getName() + "　 "

+ people_array[i] getBanji() + "　 "

+ people_array[i] getScore())

}

}

}

lishixinzhi/Article/program/Java/JSP/201311/20030

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(? , ?)}")

1. 在开发环境中加载指定数据库的驱动程序。

接下来的实验中，使用数据库MySQL，所以需要下载MySQL支持JDBC的驱动程序(mysql-connector-java-5.1.18-bin.jar)。

2. 开发环境是MyEclipse，将下载得到的驱动程序加载进开发环境中。

3. 在Java程序中加载驱动程序。

在Java程序中，通过 “Class.forName(“指定数据库的驱动程序”)” 

方式来加载添加到开发环境中的驱动程序，例如Class.forName(“com.mysql.jdbc.Driver”)。

4. 创建数据连接对象：通过DriverManager类创建数据库连接对象Connection。

DriverManager类作用于Java程序和JDBC驱动程序之间，用于检查所加载的驱动程序是否可以建立连接，然后通过它的getConnection方法，根据数据库的URL、用户名和密码，创建一个JDBC 

Connection 对象。代码如：Connection connection =  DriverManager.getConnection(“连接数据库的URL", "用户名", 

"密码”)。

    其中，URL=协议名+IP地址(域名)+端口+数据库名称；用户名和密码是指登录数据库时所使用的用户名和密码。具体示例创建MySQL的数据库连接代码如下：

              Connection connectMySQL  = 

 DriverManager.geiConnection(“jdbc:mysql://localhost:3306/myuser","root" 

,"root" )

5. 创建Statement对象：Statement 类的主要是用于执行静态 SQL 

语句并返回它所生成结果的对象。

通过Connection 对象的 createStatement()方法可以创建一个Statement对象。例如：Statement statament = 

connection.createStatement() 具体示例创建Statement对象代码如下：Statement statamentMySQL =connectMySQL.createStatement() 

6. 调用Statement对象的相关方法执行相对应的 SQL 

语句：通过execuUpdate()方法用来数据的更新，包括插入和删除等 *** 作，例如向staff表中插入一条数据的代码：

statement.excuteUpdate( "INSERT INTO 

staff(name, age, sex,address, depart, worklen,wage)" + " VALUES ('Tom1', 321, 

'M', 'china','Personnel','3','3000' ) ")  

7. 通过调用Statement对象的executeQuery()方法进行数据的查询，而查询结果会得到 

ResulSet对象，ResulSet表示执行查询数据库后返回的数据的集合，ResulSet对象具有可以指向当前数据行的指针。通过该对象的next()方法，使得指针指向下一行，然后将数据以列号或者字段名取出。如果当next()方法返回null，则表示下一行中没有数据存在。使用示例代码如下：

ResultSet resultSel = 

statement.executeQuery( "select * from staff" )

8. 关闭数据库连接：使用完数据库或者不需要访问数据库时，通过Connection的close() 方法及时关闭数据连接。

---