java程序操作MySQL数据库

数据库内容

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

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 = conncreateStatement();
num = stmtexecuteUpdate(sql);
} catch (SQLException ex) {
Systemerrprintln("执行插入有错误:" + exgetMessage());
Systemoutprint("执行插入有错误:" + exgetMessage());// 输出到客户端
}CloseDataBase();
return num;}public void CloseDataBase() {// 关闭数据库
try {
connclose();
} catch (Exception end) {
Systemerrprintln("执行关闭Connection对象有错误" + endgetMessage());
Systemoutprint("执行执行关闭Connection对象有错误有错误:" + endgetMessage()); // 输出到客户端
}
}}class people {
private String uid;
private String name;
private String banji;
private int score;public people() {
}public people(String uid String name String banji) {
thisuid = uid;
thisname = name;
thisbanji = banji;
}public people(String uid String name String banji int score) {
thisuid = uid;
thisname = name;
thisbanji = banji;
thisscore = score;
}public String getUid() {
return uid;
}public void setUid(String uid) {
thisuid = uid;
}public String getName() {
return name;
}public void setName(String name) {
thisname = name;
}public String getBanji() {
return banji;
}public void setBanji(String banji) {
thisbanji = banji;
}public int getScore() {
return score;
}public void setScore(int score) {
thisscore = score;
}}public class manage {private people[] people_array;// 对象数组public void add_people(String uid String name) {String sql = "insert people (uidname) values (" + uid + "" + name
+ ")";// sql插入语句
// String sql = "insert people (uidname) values (uidtom)";database_manage db_obj = new database_manage();
db_objupdate_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_objupdate_database(sql);}public void delete_people(String uid) {String sql = "delete from people where uid=" + uid + "";database_manage db_obj = new database_manage();db_objupdate_database(sql);}public people query_people(String uid) {
database_manage db_obj = new database_manage();
// String adminid=null;
String uid_new name banji;
uid_new = null;
name = null;
banji = null;
String sql_query = "select * from people where uid=" + uid + "";try {
ResultSet rs = db_objquery(sql_query);
if (rsnext()) {
uid_new = rsgetString("uid");
name = rsgetString("name");
banji = rsgetString("banji");
}
} catch (Exception e) {
egetMessage();
}
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 banji;
uid_new = null;
name = null;
banji = null;
int score_new = ;

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

try {

ResultSet rs = db_objquery(sql_query);// 查询后返回结果集

int num = ;

ResultSet rs_new = rs;

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

num++;

}

// Systemoutprintln(num);

people_array = new people[num];

int i = ;

rsbeforeFirst();// 返回结果集的开始

while (rsnext()) {

uid_new = rsgetString("uid");

name = rsgetString("name");

banji = rsgetString("banji");

score_new = rsgetInt("score");

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

i++;

}

} catch (Exception e) {

egetMessage();

}

return people_array;

}

public static void main(String args[]) {

/*

* people new_people=new people();

*

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

*

* new_people=mrquery_people("");//查询uid=的学生信息返回对象 Systemout

* println(""+new_peoplegetName()+" "+new_peoplegetBanji());

* mrupdate_people("" "小王");更新一个学生的信息

*

* new_people=mrquery_people("");//更新后查询

*

* Systemoutprintln(""+new_peoplegetName()+" "+new_peoplegetBanji(

* ));

*/

manage mr = new manage();

// mrdelete_people("");删除uid=的学生信息

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

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

int num = ;

num = people_arraylength;

for (int i = ; i < num; i++) {

Systemoutprintln(people_array[i]getUid() + " "

+ people_array[i]getName() + " "

+ people_array[i]getBanji() + " "

+ people_array[i]getScore());

}

}

}

程序运行结果