📄 myodbc.java
字号:
/***
*2005-11-23
*xiaoer
*用来连接数据库和数据库的操作
***/
package my.data;
import java.io.IOException;
import java.sql.*;
import java.util.Date;
public class MyOdbc{
private String driver="sun.jdbc.odbc.JdbcOdbcDriver";
//private String driver="oracle.jdbc.driver.OracleDriver";
//private String driver="com.microsoft.jdbc.sqlserver.SQLServerDriver";
//private String driver="com.mysql.jdbc.Driver";
private String url="jdbc:odbc:xxbbs";
//private String url="jdbc:oracle:thin:@localhost:1521:sid";
//private String url="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=xxbbs";
//private String url="jdbc:mysql://localhost:3360/xxbbs";
//private String user="xiaoer";
//private String pass="123456";
private Connection conn;
private Statement stmt;
private ResultSet rs;
private int i;
private boolean boo;
public MyOdbc(){
conn=null;
stmt=null;
rs=null;
}
public Connection getConn(){
try{
Class.forName(driver);
System.out.println ("找到驱动");
//DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());
//DriverManager.registerDriver(new com.mysql.jdbc.Driver());
//DriverManager.registerDriver(new com.microsoft.jdbc.sqlserver.SQLServerDriver());
}catch(Exception e){
System.out.println (e.getMessage());
System.out.println ("找不到驱动");
}
try{
conn=DriverManager.getConnection(url);
System.out.println ("连接成功");
}catch(SQLException e){
System.out.println (e.getMessage());
System.out.println ("连接数据错误");
}
return conn;
}
//判断数据库是否有要注册的用户
public boolean regUpdate(String user){
this.getConn();
String sql="select 用户名 from 用户表 where 用户名='"+user+"'";
try{
System.out.println (sql);
rs=this.executeQuery(sql);
if(rs.next()){
boo=false;
}else{
boo=true;
}
}catch(SQLException se){
System.out.println (se.getMessage());
System.out.println ("操作表出错MyOdbc 58");
}
return boo;
}
public int executeUpdate(String sql){
try{
System.out.println("SQL语句:"+sql);
conn=this.getConn();
stmt=conn.createStatement();
i=stmt.executeUpdate(sql);
}catch(SQLException e){
System.out.println (e.getMessage());
System.out.println ("数据插入出错");
}finally{
this.closeConn();
}
return i;
}
public ResultSet executeQuery(String sql){
try{
System.out.println("SQL语句:"+sql);
conn=this.getConn();
stmt=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
rs=stmt.executeQuery(sql);
}catch(SQLException e){
System.out.println (e.getMessage());
System.out.println ("数据查询出错");
}
return rs;
}
/**edit by 2005/12/16
* public int regInsert(String userId,String password,String sex,String Email,String quest,String ponse) {
sql="insert into 用户表(用户名,用户密码,性别,用户邮箱,密码问题,密码答案)values('"+userId+"','"+password+"','"+sex+"','"+Email+"','"+quest+"','"+ponse+"')";
try{
conn=this.getConn();
stmt=conn.createStatement();
i=stmt.executeUpdate(sql);
System.out.println ("数据输入成功");
}catch(SQLException se){
System.out.println (se.getMessage());
System.out.println ("操作用户表出错MyOdbc 72");
this.closeConn();
}
return i;
}
public int autReg(String userId,String password){
sql="insert into 用户表(用户名,密码)values('"+userId+"','"+password+"')";
try{
conn=this.getConn();
stmt=conn.createStatement();
i=stmt.executeUpdate(sql);
System.out.println("操作用户表出错MyOdbc 82");
}catch(SQLException e){
System.out.println (e.getMessage());
this.closeConn();
}
return i;
}
**/
//登录专用
public boolean login(String user,String password){
String sql="select * from 用户表 where 用户名='"+user+"'and 用户密码='"+password+"'";
try{
rs=this.executeQuery(sql);
if(rs.next()){
boo=true;
}else{
boo=false;
}
this.closeConn();
}catch(SQLException se){
System.out.println (se.getMessage());
System.out.println ("操作表出错MyOdbc 58");
}
return boo;
}
public boolean loginAdmin(String user,String password){
String sql="select * from 权限表 where 用户名='"+user+"' and 用户密码='"+password+"'";
try{
rs=this.executeQuery(sql);
if(rs.next()){
boo=true;
}else{
boo=false;
}
this.closeConn();
}catch(SQLException se){
System.out.println (se.getMessage());
System.out.println ("操作表出错MyOdbc 155");
}
return boo;
}
public void closeConn(){
try{
if(rs!=null){
rs.close();
System.out.println ("关闭rs");
}
if(stmt!=null){
stmt.close();
System.out.println ("关闭stmt");
}
if(conn!=null){
conn.close();
System.out.println ("关闭conn");
}
}catch(SQLException e){
System.out.println (e.getMessage());
}
}
public String getTime() {
String datestr = "" ;
try {
java.text.DateFormat df = new java.text.SimpleDateFormat("yyyy-M-d HH:ss") ;
datestr = df.format(new java.util.Date()) ;
}
catch (Exception ex) {
System.out.println (ex.getMessage());
}
return datestr ;
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -