当前位置：文档库 › mysql数据库最基本的DB操作

mysql数据库最基本的DB操作

7.3 Jsp连接mysql调用数据源方法
当jsp对于mysql数据库进行数据开发时，需要一些公用的方法，下面是jsp 调用mysql数据源的，它对mysql数据库进行查询及插入等最基本的处理。注意:你一定将mysql的jdbc的驱动程序放到服务器的类路径里。
7.3.1对mysql数据库最基本的DB操作
下面是操作mysql数据库的方法。源程序如下：
/**
*这是对mysql数据库最基本的DB操作
*/
package example7;
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class IpConn {
// private static String
// dbdriver="sun.jdbc.odbc.JDBCodbcDriver";//如果要通过odbc连接，只要把这个注释去掉
// private static String connstr="jdbc:odbc:pubs";
private static String dbdriver = " org.gjt.mm.mysql.Driver ";
private static String connstr = "jdbc:mysql://localhost/example?user=root&password=1234&useUnicode=true&characterEncoding=8859_1";
// example为你的mysql据库名，就是上面我们用工具建立的
private static Connection conn = null;
ResultSet rs = null;
private static Statement stms;
public IpConn() {
try {
Class.forName(dbdriver).newInstance();
conn = DriverManager.getConnection(connstr);
stms = conn.createStatement();
} catch (https://www.wendangku.net/doc/8d15394973.html,ng.ClassNotFoundException e) {
System.out.println("faq():" + e.toString() + e.getMessage());
} catch (Exception e) {
System.out.println("faq():" + e.toString() + e.getMessage());
}
}
/**
* 打开数据库连接
*/
public static Connection getConnection() throws SQLException {
Connection conn1 = null;
try {
Class.forName(dbdriver);
conn1 = DriverManager.getConnection(connstr, "sa", "sa");
stms = conn1.createStatement();
} catch (Exception e) {
System.err.println("DBconn (): " + e.getMessage());
}
return conn1;
}
/**
* *执行可分页的查询操作
*/
public ResultSet executeQuery3(String SQL) {
try {
stms = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
ResultSet.CONCUR_UPDATABLE);
rs = stms.executeQuery(SQL);
} catch (Exception e2) {
System.out.println("errorQuery:" + e2.toString() + e2.getMessage());
}
return rs;
}
/**
* 执行Select查询语句,可用于执行一般的SQL 查询操作
*
* @param SQL
* Select查询语句
* @return ResultSet 查询结果集
*/
public ResultSet executeQuery(String SQL) throws SQLException {
rs = null;
try {
// 取得连接对象
if (conn == null)
conn = getConnection();
stms = conn.createStatement();// 取得执行对象
rs = stms.executeQuery(SQL); // 取得结果集
} catch (Exception ex) {
System.err.println("执行SQL 语句出错：" + ex.getMessage());
}
return rs;
}
/**
* 执行更新操作, 执行一般的更新数据库操作
*
* @param SQL
* Select更新语句
*/
public void updateBatch(String SQL) throws SQLException {
try {
// 取得连接对象
if (conn == null)

conn = getConnection();
// 设置事务处理
conn.setAutoCommit(false);
String procSQL = "begin \n" + SQL + " \nend;";
CallableStatement cstmt = conn.prepareCall(procSQL);
cstmt.execute();
https://www.wendangku.net/doc/8d15394973.html,mit();
cstmt.close();
} catch (SQLException ex) {
System.err.println("执行SQL 语句出错: " + ex.getMessage());
try {
// 事务失败，回滚
conn.rollback();
} catch (Exception e) {
}
throw ex;
}
}// end public
/**
* 执行Insert,Update语句
*
* @param SQL
* Insert,Update语句
* @return null SQLException
*/
public void executeUpdate(String SQL) throws SQLException {
try {
// 取得连接对象
if (conn == null)
conn = getConnection();
// 设置事务处理
conn.setAutoCommit(false);
stms = conn.createStatement();
stms.executeUpdate(SQL);
// stmt.close();
https://www.wendangku.net/doc/8d15394973.html,mit();
// conn.close();
} catch (SQLException ex) {
System.err.println("执行SQL 语句出错: " + ex.getMessage());
try {
// 事务失败，回滚
conn.rollback();
} catch (SQLException e) {
}
throw ex;
}
}// end public executeUpdate
/**
* 提交批SQL 语句
*/
public boolean executeQuery(String[] SQL) throws Exception {
boolean flag = false;
try {
conn.setAutoCommit(false);
stms = conn.createStatement();
for (int k = 0; k < SQL.length; k++) {
if (SQL[k] != null)
stms.addBatch(SQL[k]);
}
stms.executeBatch();// 提交批SQL 语句
https://www.wendangku.net/doc/8d15394973.html,mit();
flag = true;
return flag;
} catch (Exception ex) {
try {
conn.rollback();
} catch (Exception e) {
}
System.out.println("[LinkSQL .executeQuery(String[])] : "
+ ex.getMessage());
throw new Exception("执行SQL 语句出错: " + ex.getMessage());
}
}
/**
* 转换函数转换为GBK码
*
* @param value
* 被转换的字符串
* @return String 返回转换后的字符串
*/
public static String convert(String value) {
try {
String s = new String(value.getBytes("ISO8859_1"), "GBK");
return s;
} catch (Exception e) {
String s1 = "";
return s1;
}
}
/**
* 转换函数转换为ISO8859码
*
* @param value
* 被转换的字符串
* @return String 返回转换后的字符串
*/
public static String reconvert(String value) {
try {
String s = new String(value.getBytes("GBK"), "ISO8859_1");
return s;
} catch (Exception e) {
String s1 = "";
return s1;
}
}
/**
* 释放系统资源
*
* @return null
*/
public void close() throws Exception {
try {
if (rs != null)
rs.close();
if (conn != null) {
if (!conn.isClosed()) {
if (stms != null)
stms.close();
conn.close();
}
}
} catch (Exception e) {
e.printStackTrace();
throw e;
} finally {
rs = null;
stms = null;
conn = null;
}
} // end public closeConn
/**
* 析构函数释放系统资源
*
* @return null
*/
public void close_1() {
try {
if (conn != null) {
conn.close();
}
} catch (Exception e) {
}
}
/**
* 将Date类型日期转化成String类型"任意"格式
* java.sql.Date,java.sql.Timestamp类型是java.util.Date类型的子类
* @param date Date
* @param format Strin

g
* "2003-01-01"格式
* "yyyy年M月d日"
* "yyyy-MM-dd HH:mm:ss"格式
* @return String
*/
public static String dateToString(java.util.Date date,String format) {
if (date==null || format==null) {
return null;
}
SimpleDateFormat sdf = new SimpleDateFormat(format);
String str = sdf.format(date);
return str;
}
/**
* 将String类型日期转化成java.utl.Date类型"2003-01-01"格式
* @param str String 要格式化的字符串
* @param format String
* @return Date
*/
public static java.util.Date stringToUtilDate(String str,String format) {
if (str==null||format==null) {
return null;
}
SimpleDateFormat sdf = new SimpleDateFormat(format);
java.util.Date date = null;
try
{
date = sdf.parse(str);
}
catch(Exception e)
{
}
return date;
}
}// end function
7.3.2 调用对DB操作的方法
上一节我们节绍了对数据库操作
在C:\Tomcat5\webapps\myapp\webapp目录下用记事本或editplus（一个编辑工具）编写一个文件保存为example7_1.jsp,其中表名还是我们上一节建立的表about，相关的代码如下：
<%@ page language="java" contentType="text/html; charset=gb2312" %>
<%@page language="java" import="java.sql.*" %>
//引入上节中我们建的对DB操作的基本类

测试对数据库的操作

<% ResultSet rs=null; String mysql=""; mysql="select * from about where id='1'"; //查询的SQL 语句，也可以增删改//操作，不过要调用相应的操作数据库方法
try{ rs=conn. executeQuery (mysql); //执行上面的查询语句，所用的executeQuery（）是上一节中我们定义的得到结果集的方法 .返回的结果是ResultSet类型的. %>

<% while (rs.next()) { %>

<%}; } catch(SQLException ex)//当出错是抛出异常
{ out.println(ex.getMessage());//打印异常
} finally{conn.close();}//关闭上面的连接,注意每一次对数据库的操作,都要记住用完后一定要关闭,否则会造成数据库的崩溃.
%>

号码	姓名
<%=rs.getString("id")%>	<%=conn.convert(rs.getString("name"))%>

启动Tomcat，在浏览器中输入：http://127.0.0.1:8080/myapp/webapp/ example7_1.jsp