当前位置:数据库 > SQLServer >>

java程序基础操作MySQL数据库

对MySQL数据库内容进行插入、查找、删除等一系列操作代码及运行结果
 
数据库内容: 


 
java源代码:(代码实现的是查询成绩为100的人员信息,至于其他功能的
代码中有注释)
注意:在eclipse里运行程序的时候,要工程里插入jar包,否则运行异常!
import java.sql.*;
import java.io.*;
class database_manage {
 public Connection conn = null;
 public ResultSet rs = null;
 private String DatabaseDriver = "com.mysql.jdbc.Driver";
 // DataSource 数据源名称DSN
 private String DatabaseConnStr = "jdbc:mysql://localhost:3306/people_manage?useUnicode=true&characterEncoding=utf8"
   + ",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 = null;
  try {
   conn = DriverManager
     .getConnection(
       "jdbc:mysql://localhost:3306/people_manage?useUnicode=true&characterEncoding=utf8",
       "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 = 0;
  try {
   conn = DriverManager
     .getConnection(
       "jdbc:mysql://localhost:3306/people_manage?useUnicode=true&characterEncoding=utf8",
       "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 = uid;
  this.name = name;
  this.banji = banji;
 }
 public people(String uid, String name, String banji, int score) {
  this.uid = uid;
  this.name = name;
  this.banji = banji;
  this.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_array1;// 对象数组
 public void add_people(String uid, String name) {
  String sql = "insert people (uid,name) values ('" + uid + "','" + name
    + "')";// sql插入语句
  // String sql2 = "insert people (uid,name) values ('uid001','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=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_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, banji;
  uid_new = null;
  name = null;
  banji = null;
  int score_new = 0;
  String sql_query = "select * from people where score=" + score;// sql查询语句
  try {
   ResultSet rs = db_obj.query(sql_query);// 查询后,返回结果集
   int num = 0;
   ResultSet rs_new = rs;
   while (rs_new.next()) {// 统计结果集中学生个数
    num++;
   }
   // System.out.println(num);
   people_array1 = new people[num];
   int i = 0;
   rs.beforeFirst();// 返回结果集的开始
   while (rs.next()) {
&

补充:软件开发 , Java ,
Oracle
MySQL
Access
SQLServer
DB2
Excel
SQLite
SYBASE
Postgres
如果你遇到数据库难题:
请访问www.zzzyk.com 试试
CopyRight © 2012 站长网 编程知识问答 www.zzzyk.com All Rights Reserved
部份技术文章来自网络,