opdb.java

一段用java些的留言版代码。请帮忙分析下错误。谢谢多多请教。初学者

package ymbean; 

import java.sql.*; 
import java.util.*; 
import java.text.*; 
import com.chinazjj.sql.dsql; 
import com.chinazjj.util.dutil; 
public class opDb { 
private String inquire_value=""inquire_item="",disptype="",inqtyp e="";
private String inquire_num="",inquire_addr="",inquire_name=""; 
private dutil ldutil=new dutil(); 
public opDb() { 

} 

public void setinquire_item(String name) { inquire_item= name 

;} 
public void setinquire_value( String name ) 
{ 
inquire_value = ldut il.chineseToUnicode(name);
} 
public void setdisptype(String name) { disptype=name;} 
public void setinqtype(String name) { inqtype=name;} 

public void setinquire_num( String name ) { inquire_num = ldutil.c 

hineseToUnicode(name);} 
public void setinquire_addr( String name ) { inquire_addr = ldutil 

.chineseToUnicode(name);} 
public void setinquire_name( String name ) { inquire_name = ldutil 

.chineseToUnicode(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.out.println("executeQuery: " + e) x.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"; 
dsql mysql=new dsql(); 
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"; 
dsql mysql=new dsql(); 
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," "); 
String tempToken=null; 

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

//将/n转换成为回车

public String addBr(String Content){ 
String makeContent=new String(); 
StringTokenizer strToken=new StringTokenizer(Content," "); 
while(strToken.hasMoreTokens()){ 
makeContent=makeContent+""+strToken.nextToken(); 
} 
return makeContent; 
} 

//将转换成为回车/n 
public String addCr(String Content){ 
String makeContent=new String(); 
StringTokenizer strToken=new StringTokenizer(Content,""); 
while(strToken.hasMoreTokens()){ 
makeContent=makeContent+" "+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; 
} 
}