数据库课设代码详解

2023-06-10

字数统计: 2.9k字 | 阅读时长≈ 12分

书接上回，代码要怎么写？

对数据库的操作

连接数据库，选用最经典的方法 JDBC

JDBC

Java Database Connectivity：Java访问数据库的解决方案，JDBC定义了一套标准接口，即访问数据库的通用API，不同的数据库厂商根据各自数据库的特点去实现这些接口。JDBC希望用相同的方式访问不同的数据库，让具体的数据库操作与数据库厂商实现无关，从而在不同数据库之间轻易的进行切换。

JDBC相关类与接口

1.驱动管理类 DriverManager

2.连接接口 Connection

3.语句对象接口 Statement

4.结果集接口 ResultSet

JDBC工作原理

1.Class.forName()加载驱动数据库服务器

2.DriverManager获取Connection连接获取Connection连接

3.创建Statement 执行SQL语句

4.返回ResultSet 查询结果

5.释放资源

 // 1.注册驱动,即将驱动类加载进内存中
Class.forName("com.mysql.jdbc.Driver");
// 2.获取数据库连接对象
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "root");
// 3.定义SQL语句
String sql = "update account set balance = 500 where id = 1";
// 4.获取执行SQL的对象Statement
Statement stmt = conn.createStatement();
// 5.执行SQL语句
int i = stmt.executeUpdate(sql);
// 6.处理结果
System.out.println(i);
// 7.释放资源
stmt.close();
conn.close();

DriverManager

驱动管理对象，主要功能用来注册驱动、获取数据库连接。

注册驱动

注册驱动就是告诉程序使用哪个数据库驱动包。

注册驱动时，我们写的代码为：

1	Class.forName("com.mysql.jdbc.Driver");

获取数据库连接

1	Connection conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/keyan?useUnicode=true&characterEncoding=gb2312", "root", "lbl2002312");

其中 URL 的语法格式：jdbc:mysql://ip地址(域名):端口号/数据库名称，访问本地数据库可以简写为：jdbc:mysql:///数据库名称

Connection

数据库连接对象

Statement

用于执行静态 SQL 语句并返回它所生成结果的对象

ResultSet

结果集对象，用来封装查询结果

1
2
3

next()：游标向下移动一行，并且判断当前行是否结果集最后一行的后面，如果不是返回 true，是则返回 false
getXxx(参数)：获取数据，其中参数可以是整数类型的 columnIndex，表示列的编号，从 1 开始，也可以是字符串类型的 columnLabel，表示列的名称。
例如，int getInt(1)、String getString(“name”)

Preparedstatement

表示预编译的 SQL 语句的对象

SQL 语句被预编译并存储在 PreparedStatement 对象中，然后可以使用此对象多次高效地执行该语句。

实际操作

为了在实际操作过程中实时检测访问数据库的过程，对每一个操作函数再进行一次封装，并加上一个tag，打印在控制台

打开数据库

public void open() 
{
   try 
   {
      Class.forName("com.mysql.jdbc.Driver"); 
                                                                                                                    // 用户名  密码
      conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/keyan?useUnicode=true&characterEncoding=gb2312", "root", "lbl2002312");

      //conn=DriverManager.getConnection("jdbc:mysql://localhost:8080/keyan?useUnicode=true&characterEncoding=gb2312", "root", "lbl2002312");

      stmt=conn.createStatement();
      System.out.println("打开数据库连接");
   } 
   catch (Exception ex) 
   {
   System.err.println("打开数据库时出错: " + ex.getMessage());
   }
}

关闭数据库，将连接返回给连接池

public void close() 
{
   try 
   {

      //connMgr.freeConnection("java", conn);
      conn.close();
      System.out.println ("释放连接");
   } 
   catch (SQLException ex) 
   {
      System.err.println("返还连接池出错: " + ex.getMessage());
   }
}

执行查询

public ResultSet executeQuery(String sql) throws SQLException
{
   ResultSet rs = null;
   

   rs = stmt.executeQuery(sql);
   System.out.println ("执行查询");
   return rs;
}

执行增删改

public int executeUpdate(String sql) throws SQLException
{
   int ret = 0;

   ret = stmt.executeUpdate(sql);

   System.out.println ("执行增删改");
   return ret;
}

在查询和增删改中用到了executeUpdate()和executeUpdate()函数，可以拿出来好好说道说道。

其实一共有四个函数：

executeUpdate()：执行数据库的更新、插入和删除操作，返回改变记录的行数。
executeQuery()：执行查询语句，返回结果集。
execute()：兼具上面二者的功能。
executeBatch()：执行Vector中的n个SQL语句即批量处理要执行的sql语句。

比较execute、executeUpdate的区别

相同点：
	execute与executeUpdate的相同点：都可以执行增加，删除，修改
不同点：
	不同1：

    	execute可以执行查询语句，然后通过getResultSet，把结果集取出来。

    	executeUpdate不能执行查询语句。

	不同2:

    	execute返回boolean类型，true表示执行的是查询语句，false表示执行的是insert,delete,update等等。

    	executeUpdate返回的是int，表示有多少条数据受到了影响。

这样呢，我们在进行操作时在控制台就可以看到这样的消息：

封装好之后，我们就可以直接进行调用了，如果有一个统一的大接口，由大接口再对接到小接口进行操作，那么整个代码逻辑就会清晰很多，那么我们就再定义一个大接口：

public int comUp(String sql)
{
   DBO dbo = new DBO();
   dbo.open();
   try{
      int i = dbo.executeUpdate(sql);
      if(i == 1)
      {
         return Constant.SUCCESS;
      }
      else
      {
         return Constant.SYSTEM_ERROR;
      }
   }catch(Exception e){
      e.printStackTrace();
      return Constant.SYSTEM_ERROR;
   }finally{
      dbo.close();
   }
}

public List getCom(String sql,int row)
{
   DBO dbo = new DBO();
   list = new ArrayList();
   dbo.open();
   try{
      rs = dbo.executeQuery(sql);
      while(rs.next()){
         List list2 = new ArrayList();
         for(int i=1;i<=row;i++)
         {
            list2.add(rs.getString(i));
         }
         list.add(list2);
      }
      return list;
   }catch(Exception e){
      e.printStackTrace();
      return list;
   }finally{
      dbo.close();
   }
}

功能实现

如今我们数据库的各种操作都准备好了，那么就可以进行实际功能的实现了。

这部分的代码重复性很高，举一个例子就可以了

//增加科研秘书用户
			else if(method.equals("addm")){
				String username = request.getParameter("username"); 
				String password = request.getParameter("password"); 
				String realname = request.getParameter("realname"); 
				String sex = request.getParameter("sex"); 
				String age = request.getParameter("age"); 
				String address = request.getParameter("address"); 
				String tel = request.getParameter("tel");
				// sql 检查数据库中 科研秘书有没有这个人
				String str=cBean.getString("select id from admin where username='"+username+"'");
				if(str==null)
				{
						// sql 插入
						int flag=cBean.comUp("insert into admin(username,password,realname,sex,age,address,tel,addtime,sf) " +
								"values('"+username+"','"+password+"','"+realname+"','"+sex+"','"+age+"','"+address+"','"+tel+"','"+date2+"','科研秘书')");
						if(flag == Constant.SUCCESS){ 
							request.setAttribute("message", "操作成功！");
							request.getRequestDispatcher("admin/system/index.jsp").forward(request, response); 
						}
						else { 
							request.setAttribute("message", "操作失败！");
							request.getRequestDispatcher("admin/system/index.jsp").forward(request, response); 
						} 
				}
				else
				{
					request.setAttribute("message", "该用户名已存在！");
					request.getRequestDispatcher("admin/system/index.jsp").forward(request, response); 
				} 
			}

代码结构很清楚了，就不过多解释了。

通过这一系列的操作，就可以在java代码中暴力使用“select id from admin where username=…”一类的sql语句，就很方便。

有一个比较特殊的功能值得一说：数据备份

数据备份的实现

利用Java代码实现数据库备份的方法有两种：

第一种：使用mysqldump结合exec函数进行数据库备份操作。
第二种：使用php+mysql+header函数进行数据库备份和下载操作。

我们这里只介绍第一种，也是最常使用的一种。

首先我们得知道一些mysqldump的数据库备份语句：

备份一个数据库

1	格式：mysqldump -h主机名 -P端口 -u用户名 -p密码 --database 数据库名 > 文件名.sql

备份多个数据库

1	格式：mysqldump -h主机名 -P端口 -u用户名 -p密码 --databases 数据库名1 数据库名2 数据库名3 > 文件名.sql

备份同一个数据库的多个表

1	格式：mysqldump -h主机名 -P端口 -u用户名 -p密码 --database 数据库名表1 表2 .... > 文件名.sql

备份所有数据库（一般用不上）

1	格式：mysqldump -h主机名 -P端口 -u用户名 -p密码 --all-databases > 文件名.sql

备份数据库结构不备份数据

1	格式：mysqldump -h主机名 -P端口 -u用户名 -p密码 --no-data 数据库名1 数据库名2 数据库名3 > 文件名.sql

那么就下来我将给出一个标准的代码，以及在本次课设中我实际写的代码：

标准代码：

/**
 * @param hostIP ip地址，可以是本机也可以是远程
 * @param userName 数据库的用户名
 * @param password 数据库的密码
 * @param savePath 备份的路径
 * @param fileName 备份的文件名
 * @param databaseName 需要备份的数据库的名称
 * @return
 */
public static boolean backup(String hostIP, String userName, String password, String savePath, String fileName,
                             String databaseName) {
    fileName +=".sql";
    File saveFile = new File(savePath);
    if (!saveFile.exists()) {// 如果目录不存在
        saveFile.mkdirs();// 创建文件夹
    }
    if (!savePath.endsWith(File.separator)) {
        savePath = savePath + File.separator;
    }
    //拼接命令行的命令
    StringBuilder stringBuilder = new StringBuilder();
    stringBuilder.append("mysqldump").append(" --opt").append(" -h").append(hostIP);
    stringBuilder.append(" --user=").append(userName).append(" --password=").append(password)
       .append(" --lock-all-tables=true");
    stringBuilder.append(" --result-file=").append(savePath + fileName).append(" --default-character-set=utf8 ")
            .append(databaseName);
    try {
        System.out.println(stringBuilder.toString());
        //调用外部执行exe文件的javaAPI
        Process process = Runtime.getRuntime().exec(stringBuilder.toString());
        if (process.waitFor() == 0) {// 0 表示线程正常终止。
            return true;
        }
    } catch (IOException e) {
        e.printStackTrace();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    return false;
}

以上代码是通过 Runtime.getRuntime().exec去执行数据库备份其实这条语句就相当于你进入命令行页面，也就是使用代码进入你电脑的win+R 输入cmd的页面所以如果你电脑上没有数据库，这条语句是执行不成功的

以上的java代码实现的是备份一个数据库如果你有不同的需求可以根据上面提供的mysqldump命令进行调整java中stringBuilder字符串的值。

下面是在本次课设中我实际使用的方法，就是对上面的标准代码进行简答的修改：

//备份
		else if(method.equals("bfdb"))
		{
			try {       
	            Runtime rt = Runtime.getRuntime();   
	            // 调用 mysql 的 cmd 
	            Process child = rt.exec("C:/Program Files/MySQL/MySQL Server 8.0/bin/mysqldump -uroot -plbl2002312  keyan");// 设置导出编码为utf8。这里必须是utf8
	                  
	            // 把进程执行中的控制台输出信息写入.sql文件，即生成了备份文件。注：如果不对控制台信息进行读出，则会导致进程堵塞无法运行       
	            InputStream in = child.getInputStream();// 控制台的输出信息作为输入流       
	                              
	            InputStreamReader xx = new InputStreamReader(in, "utf8");// 设置输出流编码为utf8。这里必须是utf8，否则从流中读入的是乱 

	            String inStr;       
	            StringBuffer sb = new StringBuffer("");       
	            String outStr;       
	            // 组合控制台输出信息字符串       
	            BufferedReader br = new BufferedReader(xx);       
	            while ((inStr = br.readLine()) != null)
				{
	                sb.append(inStr + "\r\n");       
	            }       
	            outStr = sb.toString();       
	                  
	            // 要用来做导入用的sql目标文件：       
	            FileOutputStream fout = new FileOutputStream("d:/db.sql");       
	            OutputStreamWriter writer = new OutputStreamWriter(fout, "utf8");       
	            writer.write(outStr);       
	            // 注：这里如果用缓冲方式写入文件的话，会导致中文乱码，用flush()方法则可以避免       
	            writer.flush();       
	      
	            // 别忘记关闭输入输出流       
	            in.close ();       
	             
	            xx.close();       
	            br.close();       
	            writer.close();       
	            fout.close();       
	      
	            request.setAttribute("message", "操作成功！");
				request.getRequestDispatcher("admin/xt/bf.jsp").forward(request, response);  
	      
	        } catch (Exception e) {       
	            e.printStackTrace();  
	            request.setAttribute("message", "操作失败！");
				request.getRequestDispatcher("admin/xt/bf.jsp").forward(request, response);
	        }       
		}

本文作者： 李宝璐
本文链接： https://libaolu312.github.io/2023/06/10/数据库课设代码详解/
版权声明： 本博客所有文章除特别声明外，均采用 MIT 许可协议。转载请注明出处！