JSP链接MYSQL数据库

JSP链接MYSQL数据库

//导入JDBC相关类
import java.sql.*;
//导入MySQL的JDBC相关类
import org.gjt.mm.mysql.*;
public class MysqlExample{
Connection conn=null;//定义数据库连接对象
Statement st=null;//定义数据库执行象
//定义连接数据库的方法
public void connectToMySQL(){
try{
Class.forName("org.gjt.mm.mysql.Driver");
/*加载JDBC驱动程序，如果找不到会出错,如果频繁的对数据库进行操作,可以把
加载的内容写在类开头的static块里,因为驱动只要加载一次就够了,没有必要在每次建立连接时加载驱动.
*/
/*
如果查找成功就尝试连接数据库，DriverManager的getConnection的方法有3个参数：
1.数据库的URL,MySQL为jdbc:mysql://hostname.port/databasename
2.数据库用户名
3.数据库密码
以下的参数只是举例而已
*/
conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/person","root","");
//如果要用到事务,必须如下设置
/*
conn.setAutoCommit(false);
*/
System.out.println("OK");//只是便于自己查看是否连接成功了
}catch(Exception e){//捕获错误
System.out.println(e.getMessage());
}
}
到此为止是完成了用connectToMySQL方法封装了对数据库的连接,当然你还可以对add,remove,query等方法对数据库里操作进行封装,最后就是一个定义一个方法connectClose(),调用close(),将st和conn关闭,当然在关闭conn之前记得conn.commit();2008-08-19

private static Connection conn=null;
public static Connection getConn(){
try {
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
conn=DriverManager.getConnection("jdbc:sqlserver://localhost:1433;databaseName=自己的数据库名","sa","");
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return conn;
}2008-08-19

一个连接数据库的bean,用起来很方便
package com;

import java.sql.*;

public class DB {

private String driverName="org.gjt.mm.mysql.Driver"; //驱动程序名(oracle: driverName="oracle.jdbc.driver.OracleDriver";)
private String userName="root"; //数据库用户名
private String userPwd="manage"; //密码
//数据库名
private String url="jdbc:mysql://localhost/test"; //连接字符串(oracle: url="jdbc:oracle:thin:@127.0.0.1:1521:orcl";)
private Connection conn=null; //数据库连接对象
public Statement stmt=null;
private ResultSet rs = null;

public DB() {
try {
Class.forName(driverName); //设置驱动程序类型
}
catch(java.lang.ClassNotFoundException e) {
e.printStackTrace();
}
}
//执行查询语句的方法
public ResultSet executeQuery(String sql) {
try {
conn = DriverManager.getConnection(url, userName, userPwd); //建立与数据库服务器的连接
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
rs = stmt.executeQuery(sql);//执行指定的数据查询语句
System.out.println("------------------数据库连接成功!");
}
catch(SQLException ex) {
ex.printStackTrace();
System.out.println("------------------数据库连接失败!");
}
return rs;
}
//执行增、删改语句的方法
public int executeUpdate(String sql) {
int result = 0;
try {
conn = DriverManager.getConnection("jdbc:mysql://localhost/test", "root", "zgy01");
stmt = conn.createStatement();
result = stmt.executeUpdate(sql);//执行指定的数据操作语句
System.out.println("------------------数据库连接成功!");
}
catch(SQLException ex) {
System.err.println(ex.getMessage());
System.out.println("------------------数据库连接失败!");
}
return result;
}
//关闭数据库连接的方法
public void close(){
if(rs!=null){
try {
rs.close();
rs = null;
} catch (SQLException e) {
e.printStackTrace();
}
}
if(stmt!=null){
try {
stmt.close();
stmt = null;
} catch (SQLException e) {
e.printStackTrace();
}
}
if(conn!=null){
try{
conn.close();
conn = null;
}catch(SQLException ex) {
System.err.println(ex.getMessage());
System.out.println("-------------------数据库关闭失败！");
}
}
}
}2008-08-19

新翼追风 回答已经很充分了2008-08-19