| 发表于:2007-10-14 18:43:44 楼主 |
<%@ page import = "java.util.*" %> <%@ page contenttype="text/html; charset=gb2312" language="java" import="java.sql.*"%> <jsp:usebean id="dbconn" scope="session" class="com.lxq.mysql.dbconnmysql" /> <% string name = request.getparameter( "username" ); string password = request.getparameter( "password" ); //以下几项请自行修改 string server = "localhost"; //mysql 服务器的地址 string dbname = "lxq"; //mysql 数据库的名字 string user = "root"; //mysql 数据库的登录用户名 string pass = "root"; //mysql 数据库的登录密码 string port = "3306"; //sql server 服务器的端口号,默认为1433 connection conn = dbconn.getconntomysql( server, dbname, user, pass, port ); statement stmt = conn.createstatement();//运行时,总是提示这一行有问题,不过是很正确的 string sql = "select * from username"; string sql1 = "insert into username (uid,pwd) values(name,password)"; stmt.EXECuteupdate( sql1 ); resultset rs = stmt.EXECutequery( sql ); while( rs.next() ) { out.print( "用户名:" ); out.print( rs.getstring( "uid" ) + " 密码:" ); out.println( rs.getstring( "pwd" ) + " <br> " ); } // rs.close(); // stmt.close(); // conn.close(); dbconn.close(); %> 这是连接mysql主要连接程序 package com.lxq.mysql; import java.beans.*; import java.sql.*; import java.sql.statement; //导入包import java.sql.*; //导入数据库操作的类 public class dbconnmysql // 构造方法,初始化 { private connection conn; // 连接对象 private statement stmt; // 语句对象 private resultset rs; // 结果集对象 private string mysqldriver; // mysql server驱动程序字符串 private string mysqlurl; // mysql server连接字符串 // *********************************用 org.gjt.mm.mysql.driver 驱动 // 该方法取得连接所需各种参数,组成连接字符串, // 然后再建立连接* server;dbname,user,pass,port 分别表示mysql 服务器的地址,* // 数据库,用户名,密码,端口**********************************/ public connection getconntomysql(string server, string dbname, string user, string pass, string port) {// mysql驱动程序 mysqldriver = "com.mysql.jdbc.driver"; mysqlurl = "jdbc:mysql://"; // 连接字符串一部分 try { // 完整的连接字符串 mysqlurl = mysqlurl + server + ":" + port + "/" + dbname + "," + user + "," + pass; class.forname( mysqldriver ); conn = drivermanager.getconnection( mysqlurl ); } catch( exception e ) { system.out.println( "操作数据库出错,请仔细检查" ); // system.err.println( e.getmessage() ); } return conn; } // 关闭数据库连接 public void close() { try {// rs.close(); // stmt.close(); conn.close(); } catch( sqlexception sqlexception ) { sqlexception.printstacktrace(); } } } |
|
|
|
|