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

java连接mysql数据库的步骤如下：

首先要下载mysql-connection-java-5.0.16-bin.jar这个jar包（版本不一致没关系），然后在工程中导入该库文件。

然后写一个类（DBHelper）用来打开或关闭数据库：

package com.hu.demo

import java.sql.Connection

import java.sql.DriverManager

import java.sql.PreparedStatement

import java.sql.SQLException

public class DBHelper {

public static final String url = "jdbc:mysql://127.0.0.1/student"

public static final String name = "com.mysql.jdbc.Driver"

public static final String user = "root"

public static final String password = "root"

public Connection conn = null

public PreparedStatement pst = null

public DBHelper(String sql) {

try {

Class.forName(name)//指定连接类型

conn = DriverManager.getConnection(url, user, password)//获取连接

pst = conn.prepareStatement(sql)//准备执行语句

} catch (Exception e) {

e.printStackTrace()

}

}

public void close() {

try {

this.conn.close()

this.pst.close()

} catch (SQLException e) {

e.printStackTrace()

}

}

}

最后再写一个Demo类来执行相关查询 *** 作：

package com.hu.demo

import java.sql.ResultSet

import java.sql.SQLException

public class Demo {

static String sql = null

static DBHelper db1 = null

static ResultSet ret = null

public static void main(String[] args) {

sql = "select *from stuinfo"//SQL语句

db1 = new DBHelper(sql)//创建DBHelper对象

try {

ret = db1.pst.executeQuery()//执行语句，得到结果集

while (ret.next()) {

String uid = ret.getString(1)

String ufname = ret.getString(2)

String ulname = ret.getString(3)

String udate = ret.getString(4)

System.out.println(uid + "\t" + ufname + "\t" + ulname + "\t" + udate )

}//显示数据

ret.close()

db1.close()//关闭连接

} catch (SQLException e) {

e.printStackTrace()

}

}

}

这样就完成了mysql数据库的连接了。

可以用JDBC执行 create database daname这类语句建立数据库、表初始数据。

程序此一次运行，可以在异常里捕捉 数据库找不到异常…… 执行数据库创建之类的代码

---