opdb.java

大型数据库课程设计源码

package mybeans;

import java.sql.*; 
import java.util.*; 
import java.text.*; 

public class opDb { 

private String inquire_value="",inquire_item="",disptype="",inqtype=""; 
private String inquire_num="",inquire_addr="",inquire_name=""; 

public opDb() { 

} 

public void setinquire_item(String name) { inquire_item= name ;} 
public void setinquire_value( String name ) { inquire_value = name;} 
public void setdisptype(String name) { disptype=name;} 
public void setinqtype(String name) { inqtype=name;} 

public void setinquire_num( String name ) { inquire_num = name;} 
public void setinquire_addr( String name ) { inquire_addr =name;} 
public void setinquire_name( String name ) { inquire_name =name;} 

public String getinquire_dndata() 
{ 
return ""; 
} 

public ResultSet executeQuery(String sql) 
{ 
ResultSet rs = null; 
Statement lstmt = null; 
try { 
lstmt = connectdb(); 
rs = lstmt.executeQuery(sql); 
System.out.println("executeQuery: "+sql); 
} catch(SQLException ex) { System.err.println("executeQuery: " + 

ex.getMessage());} 
return rs; 
} 

public Statement getStmt() 
{ 
Statement lstmt = null; 
lstmt = connectdb(); 
return lstmt; 
} 

public String executeUpdate(String sql) 
{ 
ResultSet rs = null; 
Statement lstmt = null; 
try { 
lstmt = connectdb(); 
lstmt.executeUpdate(sql); 
System.out.println("executeUpdate: "+sql); 
lstmt.executeUpdate("commit"); 
} 
catch(SQLException ex) { System.err.println("executeQuery: " + ex.getMessage()); 
return(ex.getMessage()); 
} 
return("executeUpdate ok"); 
} 

public Statement connectdb() 
{ 

Statement lstmt=null; 
Connection conn=null; 

final String connect_string="jdbc:oracle:thin:scott/tiger@192.168.0.1:1521:clubdb"; 
final String driver_string="oracle.jdbc.driver.OracleDriver";
//lstmt=mysql.dconnectdb(driver_string,connect_string); 
return lstmt; 
} 

public Statement connectdb(String connect_string) 
{ 
Statement lstmt=null; 
Connection conn=null; 

final String driver_string="oracle.jdbc.driver.OracleDriver";
//lstmt=mysql.dconnectdb(driver_string,connect_string); 
return lstmt; 
} 


//=========other function =================================== 

public String getCurrentDate(String ldateform) 
{ 
return(new SimpleDateFormat(ldateform).format(new java.util.Date( 

))); 
} 


public String removeComment(String Content){ 
String makeContent=new String(); 
StringTokenizer strToken=new StringTokenizer(Content,"\n"); 
String tempToken=null; 

while(strToken.hasMoreTokens()){ 
tempToken=strToken.nextToken(); 
if(tempToken.indexOf(":")!=0) 
makeContent=makeContent+tempToken+"\n"; 
} 
return makeContent; 
} 

//将/n转换成为回车<br> 
public String addBr(String Content){ 
String makeContent=new String(); 
StringTokenizer strToken=new StringTokenizer(Content,"\n"); 
while(strToken.hasMoreTokens()){ 
makeContent=makeContent+"<br>"+strToken.nextToken(); 
} 
return makeContent; 
} 

//将<br>转换成为回车/n 
public String addCr(String Content){ 
String makeContent=new String(); 
StringTokenizer strToken=new StringTokenizer(Content,"<br>"); 
while(strToken.hasMoreTokens()){ 
makeContent=makeContent+"\n"+strToken.nextToken(); 
} 
return makeContent; 
} 



public boolean getIdentify(String name1,String pwd1) 
{ 
try 
{ 
String sql="select * from club_users where username='" + name1 + "'and password='" + pwd1 + "'"; 
ResultSet rs = executeQuery(sql); 
if(rs.next()) { rs.close(); return(true);} 
else { rs.close();return(false);} 
}catch (Exception e) { return(false);} 
} 

public void counts(String pagename) 
{ 
executeUpdate("update call_count set counts=counts + 1 where pagename='"+pagename+"'"); 

} 


public String getDeptSuper(String vp) //取版主 
{ 
String vst="未知"; 
try{ 
String sql="select administrator from club_cvcdept where deptno='"+vp+"'"; 
ResultSet rs = executeQuery(sql); 
if(rs.next()) vst=rs.getString(1); 
rs.close(); 
} catch (Exception e) {} 
return vst; 
} 
public String getDeptName(String vp) //取版名 
{ 
String vst="未知"; 
try{ 
String sql="select deptnote from club_cvcdept where deptno='"+vp 

+"'"; 
ResultSet rs = executeQuery(sql); 
if(rs.next()) vst=rs.getString(1); 
rs.close(); 
} catch (Exception e) {} 
return vst; 
} 

public String getUserEmail(String vp) //取社区用户email 
{ 
String vst="未知"; 
try{ 
String sql="select email from club_users where username='"+vp+"'"; 
ResultSet rs = executeQuery(sql); 
if(rs.next()) vst=rs.getString(1); 
rs.close(); 
} catch (Exception e) {} 
return vst; 
} 

public Object getaValue(String vp) //取社区用户email及其他 
{ 
Object vst=null; 
try{ 
String sql=vp; 
ResultSet rs = executeQuery(sql); 
if(rs.next()) vst=rs.getObject(1); 
rs.close(); 
} catch (Exception e) {} 
return vst; 
} 

public String getsValue(String vp) //取社区用户email及其他 
{ 
String vst=""; 
try{ 
String sql=vp; 
ResultSet rs = executeQuery(sql); 
if(rs.next()) vst=rs.getString(1); 
rs.close(); 
} catch (Exception e) {} 
return vst; 
} 


}//end opDb.java