connpara.java

五个java源程序

ConnPara para= new ConnPara(sqlStr);<br>
url=para.url;<br>
user=para.user;<br>
password=para.password;<br>
sDriver=para.sDriver;<br>
try {<br>
Class.forName(sDriver);<br>
con=java.sql.DriverManager.getConnection(url,user,password);<br>
stat=con.createStatement();<br>
result=stat.executeQuery(gener.N2U(doWithSqlStr(sqlStr))); // 
System.out.println(&quot;doWithSqlStr=&quot;+doWithSqlStr(sqlStr));<br>
//System.out.println(&quot; marker after exce sql &quot;+sqlStr );<br>
if( !result.next() ){ // if no value , let it return null Hashtable<br>
System.out.print(&quot;\n************ resule is null successed selectAll(String sqlStr) 
**********\n&quot;);<br>
con.close();<br>
return ht;<br>
}<br>
// 处理这个结果集 放入 ht 里。 //<br>
String fields1=sqlStr.substring(7, sqlStr.indexOf(&quot;from&quot;));<br>
String fields=null;<br>
String fieldName=null,tempStr;<br>
int ii=1,idii=0 ; String sApp;<br>
String addValues=null;<br>
do { // 让它循环 result<br>
fields=fields1;<br>
while (fields.trim().length()!=0 ) {<br>
if (fields.indexOf(&quot;,&quot;)==-1) {<br>
fieldName=fields;<br>
fields=&quot;&quot;;<br>
}else {<br>
fieldName=fields.substring(0,fields.indexOf(&quot;,&quot;));<br>
fields=fields.substring(fields.indexOf(&quot;,&quot;)+1);<br>
}<br>
fieldName=fieldName.trim();<br>
if (fieldName.indexOf(&quot;Int&quot;)!=-1 ) {<br>
fieldName=fieldName.substring(0, fieldName.indexOf(&quot;Int&quot;));<br>
sApp=result.getInt(fieldName)+&quot;&quot;;<br>
} else if ( fieldName.indexOf(&quot;Float&quot;)!=-1 ) {<br>
fieldName=fieldName.substring(0, fieldName.indexOf(&quot;Float&quot;));<br>
sApp=result.getFloat(fieldName)+&quot;&quot;;<br>
} else if ( fieldName.indexOf(&quot;Double&quot;)!=-1 ) {<br>
fieldName=fieldName.substring(0, fieldName.indexOf(&quot;Double&quot;));<br>
sApp=result.getDouble(fieldName)+&quot;&quot;;<br>
} else if (fieldName.indexOf(&quot;=&quot;)!=-1 ){ // 
这是认为查询的是字符串并且内有=<br>
fieldName=fieldName.substring(0, fieldName.indexOf(&quot;=&quot;));<br>
sApp=gener.base(result.getString(fieldName));<br>
}else{<br>
sApp=gener.base(result.getString(fieldName));<br>
}<br>
sApp=&quot; &quot;+sApp;<br>
sApp=sApp.trim();<br>
if (sApp.equals(&quot;&quot;) &amp;&amp; sApp==null ) {<br>
sApp=&quot; &quot;;<br>
}<br>
ht.addElement(sApp); // add this obj .<br>
// System.out.println(&quot;\n('&quot;+idii+&quot;', &quot;+fieldName+&quot; 
'&quot;+sApp+&quot;') already load&quot;);<br>
fields=fields.trim();<br>
idii=idii+1;<br>
}<br>
} while(result.next());<br>
con.close();<br>
System.out.println(&quot;\n\n******* sql execue Succend *************\n&quot;);<br>
return ht;<br>
} catch (Exception ye) {<br>
System.out.print(&quot;\n 在执行sql时出现异常:\n&quot;+ye.toString()) ;<br>
System.out.println(&quot;\n\n******* sql execue Error *************\n&quot;);<br>
try {<br>
con.close();<br>
} catch (Exception ffye) {}<br>
}<br>
return ht ;<br>
}<br>
// this mothe doWith the sql<br>
public static Vector result(String data) {<br>
Vector vec=null; String str=null;<br>
// data=&quot;200^zhou0530^123&quot;;<br>
data=&quot;20&quot;;<br>
if (data.indexOf(&quot;^&quot;)==-1) return vec;<br>
data=data.substring(0,2);<br>
System.out.println(&quot;Data=&quot;+data);<br>
while (data.indexOf(&quot;^&quot;)!=-1) {<br>
data=data.substring(1); // 把&quot;^&quot;去掉<br>
vec.addElement(data.substring(0,data.indexOf(&quot;^&quot;)-1));<br>
data=data.substring(data.indexOf(&quot;^&quot;));<br>
}<br>
return vec;<br>
}<br>
public static String doWithSqlStr( String sqlStr ) {<br>
String sql=sqlStr, str0=null,str1=null;<br>
// System.out.println(&quot;\nWill deal with String is:\n &quot;+sql );<br>
int len=sql.length();<br>
try {<br>
while((sql.indexOf(&quot;Int&quot;)!=-1)||(sql.indexOf(&quot;Float&quot;)!=-1)) {<br>
if (sql.indexOf(&quot;Int&quot;)!=-1) {<br>
str0=sql.substring(0,sql.indexOf(&quot;Int&quot;));<br>
str1=sql.substring(sql.indexOf(&quot;Int&quot;)+3,len);<br>
sql=str0+str1;<br>
len=sql.length();<br>
}<br>
if (sql.indexOf(&quot;Float&quot;)!=-1) {<br>
str0=sql.substring(0,sql.indexOf(&quot;Float&quot;));<br>
str1=sql.substring(sql.indexOf(&quot;Float&quot;)+5,len);<br>
sql=str0+str1;<br>
len=sql.length();<br>
}<br>
}<br>
} catch (Exception ye) {<br>
System.out.println(&quot;\nError:When turn the sqlStr\n &quot;+ye.toString() );<br>
return ye.toString();<br>
}<br>
// System.out.println(sql+&quot;\n is return \n&quot;);<br>
return sql;<br>
}<br>
/*<br>
有关mailTo 的说明请参见Class SendMail 类上面的说明 .<br>
*/<br>
public static String mailTo(String mailTo, String subject,String doc ) {<br>
String sHostName = &quot;100.0.0.3&quot;; // 定义一个发mail 的server<br>
int nPort = 25; // 定义一个端口号在 Internet 组织固定的端口号<br>
String comeFrom=&quot;[e-mail]&quot; ;<br>
// 定义一个向外发mail 的帐号就是用这个帐号向外发mail<br>
try {<br>
String str=null;<br>
Socket sktMail = new Socket(sHostName,nPort);<br>
PrintStream ps = new PrintStream(sktMail.getOutputStream());<br>
ps.println(&quot;\nHELO &quot; + sHostName);<br>
System.out.println(&quot; ***** now send mail start ****** &quot;);<br>
DataInputStream disReply = new java.io.DataInputStream(sktMail.getInputStream());<br>
str=disReply.readLine();<br>
System.out.println(&quot;return info &quot;+str);<br>
ps.println(&quot;MAIL FROM: &quot; + comeFrom );<br>
str=disReply.readLine();<br>
System.out.println(&quot;MAIL FROM=&quot;+str);<br>
ps.println(&quot;RCPT TO: &quot; + mailTo );<br>
str=disReply.readLine();<br>
System.out.println(&quot;RCPT TO=&quot;+str);<br>
ps.println(&quot;DATA&quot;);<br>
str=disReply.readLine();<br>
System.out.println(&quot;DATA=&quot;+str);<br>
ps.println(&quot;From: &quot; + comeFrom + &quot;\n&quot; + &quot;Subject:&quot; + subject 
+&quot;\n&quot; + doc +&quot;\n&quot; + &quot;.&quot; + &quot;\n&quot;);<br>
str=disReply.readLine();<br>
System.out.println(&quot;From=&quot;+str);<br>
ps.println(&quot;QUIT&quot;);<br>
str=disReply.readLine();<br>
System.out.println(&quot;quit=&quot;+str);<br>
System.out.println(&quot; ***** mail send ok ****** &quot;);<br>
ps.close();<br>
sktMail.close();<br>
return &quot;1&quot; ;<br>
} catch (IOException e) {<br>
System.out.println(&quot;Error=&quot;+e.toString()+&quot;\n ***** mail send Error 
******&quot;);<br>
return e.toString();<br>
}<br>
}<br>
<br>
}<br>
/*<br>
<br>
******* 有关 SMTP 协议的说明如下。 *******<br>
1. 发mail 有一个固定的格式。这个格式也叫协议。尊守这个协议才<br>
能正确的发送. 如:<br>
1,FROM: 这个标记后面写的是从那里来的。<br>
2,SUBJECT : 这个标记是标题是什么<br>
2. mail的发送的命令如下:<br>
HELO 是SendMail 用来标识自己的命令<br>
MAIL FROM 是用来标识自己的命令<br>
RCPT TO 
是用来标识收件人的命令。可以重复几次把一个文件发给多个人。<br>
所说的重复几次就是多执行几次这个命令 。<br>
DATA 是所有的用户都指定后。发送方准备传输信息了。(现在发送信息)<br>
QUIT 被用来告诉收方，已经完成了发送，这个连接可以断开。<br>
3. 来自己接受SendMail程序相应是以三个数字开始的。后面有文本对这个数字信息进行解释。<br>
2XX 表示一切正常.<br>
4XX 表示有一错误消息，但不是致命的 它是一个暂时的现象(如，服务暂无效, 
可以重试一次。)<br>
5XX 表示不可改正的错误信息。如语法错误。<br>
<br>
******* 有关 SendMail 的说明如下 ******<br>
1、mailTo 是收件人的mail地址，它可以用向多个人发mail说明的是必须用&quot; 
; &quot; 把各个地址隔开<br>
2、在使用时可以修改属性以符合自己的要求。(mailFrom , sHostName , 
subject )<br>
<br>
*/<br>
class SendMail {<br>
public String sHostName = &quot;100.0.0.3&quot;; // 定义一个发mail 的server<br>
public String mailTo=&quot;[e-mail]&quot;;<br>
public String doc=&quot; this option no initial&quot;;<br>
public String mailFrom=&quot;[e-mail]&quot; ;<br>
public String subject=&quot;Hello this is &quot;+mailFrom ;<br>
public void resert(){ // 重置当前的参数<br>
mailTo=&quot;[e-mail]&quot;;<br>
doc=&quot; this option no initial &quot;;<br>
mailFrom=&quot;[e-mail]&quot; ;<br>
subject=&quot;Hello this is &quot;+mailFrom ;<br>
}<br>
public static void errorLog(String log ){<br>
try {<br>
FileOutputStream fos= new FileOutputStream(&quot;d:error.txt&quot;,true); // 
建立一个文件输出流<br>
fos.write(log.getBytes());<br>
fos.close();<br>
} catch(Exception ee) {<br>
System.out.println(ee.toString());<br>
}<br>
}<br>
public String send() {<br>
int nPort = 25; // 定义一个端口号在 Internet 组织固定的端口号<br>
String sTemp1, sTemp2;<br>
try {<br>
String str=null;<br>
Socket sktMail = new Socket(sHostName,nPort);<br>
PrintStream ps = new PrintStream(sktMail.getOutputStream());<br>
ps.println(&quot;\nHELO &quot; + sHostName);<br>
System.out.println(&quot;****** now send mail start ****** &quot;);<br>
//System.out.println(&quot;mailFrom:&quot;+mailFrom );<br>
//System.out.println(&quot;mailTo :&quot;+mailTo );<br>
//System.out.println(&quot;subject :&quot;+subject );<br>
DataInputStream disReply = new java.io.DataInputStream(sktMail.getInputStream());<br>
str=disReply.readLine();<br>
ps.println(&quot;MAIL FROM: &quot; + mailFrom );<br>
str=disReply.readLine();<br>
// 重复使用 RCPT TO 命令让其发到多个用户上<br>
sTemp1=mailTo.trim();<br>
while (!sTemp1.trim().equals(&quot;&quot;)) {<br>
if (sTemp1.indexOf(&quot;;&quot;)==-1 ) {<br>
sTemp2=sTemp1;<br>
sTemp1=&quot;&quot;;<br>
}else{<br>
sTemp2=sTemp1.substring(0,sTemp1.indexOf(&quot;;&quot;));<br>
sTemp1=sTemp1.substring(sTemp1.indexOf(&quot;;&quot;)+1 );<br>
}<br>
if (!sTemp2.equals(&quot;&quot;)) {<br>
ps.println(&quot;RCPT TO: &quot; +sTemp2 );<br>
str=disReply.readLine(); // 应答信息<br>
}<br>
// 写入一个文件里<br>
// errorLog(str);<br>
}<br>
ps.println(&quot;DATA&quot;);<br>
str=disReply.readLine();<br>
// 必须有\n否 不会出现标题<br>
ps.println(&quot;From:&quot;+mailFrom+&quot;\n&quot;+&quot;Subject:&quot;+subject+&quot;\n&quot; 
+ doc +&quot;\n&quot; + &quot;.&quot; + &quot;\n&quot;);<br>
str=disReply.readLine();<br>
ps.println(&quot;QUIT&quot;);<br>
str=disReply.readLine();<br>
System.out.println(&quot; ***** mail send ok ****** &quot;);<br>
ps.close();<br>
sktMail.close();<br>
return &quot;1&quot; ;<br>
} catch (IOException e) {<br>
System.out.println(&quot;Error=&quot;+e.toString()+&quot;\n ***** mail send Error 
******&quot;);<br>
return e.toString();<br>
}<br>
}<br>
}<br>
<br>
<br>
</p>
</body>
</html>