stringsql

『壹』 c#連接mysql的字元串 應該怎麼寫

這里將介紹C#資料庫查詢和操作方面的有關知識，包括資料庫連接、資料庫查詢的相關代碼和示例。希望本文對大家有所幫助。

一：C#資料庫查詢之資料庫連接代碼：

SqlConnectionobjSqlConnection=newSqlConnection("server=127.0.0.1;uid=sa;pwd=;database=test"); objSqlConnection.Open(); 二：資料庫的添加記錄代碼：

inti=0; strings1="",s2=""; i=Convert.ToInt16(textBox1.Text); s1=textBox2.Text; s2=textBox3.Text; SqlConnectionobjSqlConnection=newSqlConnection("server=127.0.0.1;uid=sa;pwd=;database=test"); objSqlConnection.Open(); MessageBox.Show("資料庫連接成功","好"); try { SqlCommandsqlcom=newSqlCommand("insertintoinfo(id,name,sex)values("+i+",'"+s1+"','"+s2+"')",objSqlConnection); sqlcom.ExecuteNonQuery(); MessageBox.Show("添加成功！","啊"); } catch(Exceptiona) { MessageBox.Show(a.ToString()); } MessageBox.Show("添加成功！","啊"); } 三：資料庫的修改代碼：

inti=0; strings1="",s2=""; s1=textBox2.Text; s2=textBox3.Text; if(textBox1.Text.Length==0) i=0; else i=Convert.ToInt32(textBox1.Text); SqlConnectionobjSqlConnection=newSqlConnection("server=127.0.0.1;uid=sa;pwd=;database=test"); objSqlConnection.Open(); MessageBox.Show("資料庫連接成功","好"); try { SqlCommandsqlcom=newSqlCommand("updateinfosetname='"+s1+"',sex='"+s2+"'"+"whereid="+i,objSqlConnection); sqlcom.ExecuteNonQuery(); MessageBox.Show("修改成功！","啊"); objSqlConnection.Close(); } catch(Exceptiona) { MessageBox.Show(a.ToString()); } 四：資料庫的刪除代碼：

inti=0; strings1="",s2=""; s1=textBox2.Text; s2=textBox3.Text; if(textBox1.Text.Length==0) i=0; else i=Convert.ToInt16(textBox1.Text); SqlConnectionobjSqlConnection=newSqlConnection("server=127.0.0.1;uid=sa;pwd=;database=test"); objSqlConnection.Open(); MessageBox.Show("資料庫連接成功","好"); try { SqlCommandsqlcom=newSqlCommand("deletefrominfowhereid="+i,objSqlConnection); sqlcom.ExecuteNonQuery(); MessageBox.Show("刪除成功！","啊"); objSqlConnection.Close(); } catch(Exceptiona) { MessageBox.Show(a.ToString()); } 五：資料庫的查詢代碼：

1.類開始：

DataTabledt1=newDataTable(); SqlDataAdapterda1=newSqlDataAdapter(); 2.按鈕代碼：

inti=0,n=0; strings1="",s2=""; s1=textBox2.Text; s2=textBox3.Text; if(textBox1.Text.Length==0) i=0; else i=Convert.ToInt32(textBox1.Text); SqlConnectionobjSqlConnection=newSqlConnection("server=127.0.0.1;uid=sa;pwd=;database=test"); objSqlConnection.Open(); MessageBox.Show("資料庫連接成功","好"); stringquery="SELECT*frominfowhereid="+i; DataSetobjDataSet=newDataSet(); SqlDataAdapterobj=newSqlDataAdapter(); obj.SelectCommand=newSqlCommand(query,objSqlConnection); obj.Fill(objDataSet,"info"); SqlCommandobjSqlCommand=newSqlCommand(query,objSqlConnection); SqlDataReaderobjSqlReader=objSqlCommand.ExecuteReader(); while(objSqlReader.Read()) { n+=1; MessageBox.Show("編號:"+objSqlReader.Getvalue(0)+"姓名:"+objSqlReader.Getvalue(1)+"性別"+objSqlReader.Getvalue(2)); } if(n==0) MessageBox.Show("資料庫中沒有這樣的記錄！"); 六：C#資料庫查詢代碼：

inti=0; //intn=0; strings1="",s2=""; stringsql; s1=textBox2.Text; s2=textBox3.Text; if(textBox1.Text.Length==0) { i=0; } else i=Convert.ToInt32(textBox1.Text); SqlConnectionobjSqlConnection=newSqlConnection("server=127.0.0.1;uid=sa;pwd=;database=test"); objSqlConnection.Open(); MessageBox.Show("資料庫連接成功","好"); stringquery="SELECT*frominfowhereid="+i; if(i==0) sql="select*frominfo"; else sql="select*frominfowhereid="+i; da1=newSqlDataAdapter(sql,objSqlConnection); dt1.Clear(); da1.Fill(dt1); dataGridView1.DataSource=dt1; C#資料庫查詢之資料庫的封裝類代碼：

classDBClass { publicvoiddbclass(stringsql) { try { SqlConnectionsqlcon=newSqlConnection("server=127.0.0.1;uid=sa;pwd=;database=test"); sqlcon.Open(); SqlTransactionobjt=sqlcon.BeginTransaction();//事物開始 SqlCommandsqlcom=newSqlCommand(sql,sqlcon); sqlcom.Transaction=objt;//將Command對象設置為事物處理的對象 sqlcom.ExecuteNonQuery(); objt.Commit();//提交事物 sqlcon.Close(); } catch(Exceptiona) { MessageBox.Show(a.ToString()); } } } --db2資料庫連接代碼： stringstrcon="Provider=IBMDADB2;DataSource=hfzd;UserId=db2admin;Password=db2admin"; //stringsql="select*fromADMINISTRATOR.HFZD"; stringsql="deletefromADMINISTRATOR.HFZDwhereID=1"; OleDbConnectionolecon=newOleDbConnection(strcon); olecon.Open(); MessageBox.Show("資料庫已連接上"); dt.Clear(); da=newOleDbDataAdapter(sql,olecon); da.Fill(dt); dataGridView1.DataSource=dt; olecon.Close();

『貳』 java 將數據保存到資料庫的問題 SQL語句

先將T表中得到的結果集存在數組中,最後是以javabean那樣的.然後得到name
id
sex
相對應然後插入進去!如果只是一條數據,那就更簡單了,直接用變數得到後,編寫插入的SQL語句,然後執行就行了

『叄』 JAVA 關於調用資料庫

<%
DbConnect
db
=
DbConnect.getInstance();//獲取一個連接實例
Connection
conn
=
db.getConnect();//取得一個連接
String
sql="select
*from
(select
*from
notice_hanchao
order
by
insert_time
desc)";//一個查詢字元串
PreparedStatement
ps
=
conn.prepareStatement(sql);//把查詢字元串構造成一個語句對象
ResultSet
rs
=
ps.executeQuery();//執行語句，並返回一個結果集
%>

『肆』 java怎樣連接mysql資料庫

1、java連接MySQL資料庫需要有一個驅動jar包

例如：mysql-connector-java-5.1.26-bin.jar,

package.test.jsp;
importjava.sql.Connection;
importjava.sql.DriverManager;
importjava.sql.ResultSet;
importjava.sql.SQLException;
importjava.sql.Statement;

importjavax.naming.spi.DirStateFactory.Result;

publicclassDbConnection{
privatestaticConnectionconn;
publicDbConnection(){
Stringdrivername="com.mysql.jdbc.Driver";
Stringusername="root";
Stringurl="jdbc:mysql://localhost/jsptest?useUnicode=true&characterEncoding=UTF-8";
Stringpassword="";
//載入驅動
try{
Class.forName(drivername);
}catch(ClassNotFoundExceptione){
System.out.println("驅動載入失敗！");
e.printStackTrace();
}
//建立連接
try{
conn=DriverManager.getConnection(url,username,password);
}catch(SQLExceptione){
System.out.println("資料庫連接失敗！");
e.printStackTrace();
}


}
//getResultSet
publicResultSetGetResultSet(Stringsql)
{
ResultSetrs=null;
//statemanage
try{
Statementst=conn.createStatement();
rs=st.executeQuery(sql);
}catch(SQLExceptione){
System.out.println("狀態管理器創建失敗");
e.printStackTrace();
}
returnrs;

}
//DML
publicintDML(Stringsql)
{
intcount=-1;
try{
Statementstatement=conn.createStatement();
count=statement.executeUpdate(sql);
}catch(SQLExceptione){
System.out.println("狀態管理器創建失敗");
e.printStackTrace();
}
returncount;
}
}

3、可以新建service類來調用連接類裡面的getResultSet方法和DML，實現自己所需用的功能。

『伍』 寫一段代碼

資料庫的建立應該不用再講了吧，現在講使用JAVA與資料庫進行交互使用JDBC進行資料庫的增刪改查操作1.下載MicrosoftSQLServer2005JDBC驅動包jar文件將jar文件引入工程中2.封裝資料庫鏈接的獲取和關閉操作importjava.sql.*;publicclassBaseDao{/***資料庫驅動類的字元串,完整的包名加類名在工程中查看添加的jar文件能看到這個類*/privatestaticfinalStringDRIVE="com.microsoft.sqlserver.jdbc.SQLServerDriver";/***資料庫連接地址**DataBaseName=資料庫名稱其它固定*/privatestaticfinalStringURL="jdbc:sqlserver://localhost:1433;DataBaseName=bbs";/***連接資料庫的用戶名*/privatestaticfinalStringUSER="sa";/***用戶密碼*/="";/***獲取連接異常直接拋出或者捕獲後自定義異常信息再拋出*/()throwsException{Class.forName(DRIVE);returnDriverManager.getConnection(URL,USER,PASSWORD);}/***關閉與資料庫的連接釋放資源*/publicstaticvoidcloseAll(ResultSetresultSet,PreparedStatementpst,Connectionconnection)throwsException{if(resultSet!=null)resultSet.close();if(pst!=null)pst.close();if(connection!=null)connection.close();}}3.創建圖書的實體類publicclassBook{/***資料庫主鍵*/privateLongid;/***作者*/privateStringauthor;/***書名*/privateStringname;/***默認構造**/publicBook(){}/***全欄位構造*@paramid*@paramauthor*@paramname*/publicBook(Longid,Stringauthor,Stringname){this.id=id;this.author=author;this.name=name;}/***以下為讀寫屬性的方法*@return*/publicStringgetAuthor(){returnauthor;}publicvoidsetAuthor(Stringauthor){this.author=author;}publicLonggetId(){returnid;}publicvoidsetId(Longid){this.id=id;}publicStringgetName(){returnname;}publicvoidsetName(Stringname){this.name=name;}}4.創建與圖書表交互的工具類importjava.sql.Connection;importjava.sql.PreparedStatement;importjava.sql.ResultSet;importjava.util.ArrayList;importjava.util.List;publicclassBookDao{/***添加新書**@parambook要添加入資料庫的圖書作者書名必須給定*/publicvoidaddBook(Bookbook)throwsException{//連接Connectionconnection=null;//執行語句PreparedStatementpst=null;try{connection=BaseDao.getConnection();//構造執行語句Stringsql="insertintobookvalues("+book.getAuthor()+","+book.getName()+")";pst=connection.prepareStatement(sql);pst.executeUpdate();}catch(Exceptione){//拋出異常throwe;}finally{//無論是否異常均關閉資料庫BaseDao.closeAll(null,pst,connection);}}/***查詢所有書籍列表*/publicListgetBooks()throwsException{//用於存放查尋結果的集合Listbooks=newArrayList();//連接Connectionconnection=null;//執行語句PreparedStatementpst=null;//查詢結果ResultSetresultSet=null;try{connection=BaseDao.getConnection();//構造查詢語句Stringsql="select*frombook";pst=connection.prepareStatement(sql);resultSet=pst.executeQuery();//循環讀取查詢結果行while(resultSet.next()){//getXXX的參數為數據表列名Bookbook=newBook(resultSet.getLong("id"),resultSet.getString("author"),resultSet.getString("name"));//將封裝好的圖書對象存入集合books.add(book);}}catch(Exceptione){//拋出異常throwe;}finally{//無論是否異常均關閉資料庫BaseDao.closeAll(resultSet,pst,connection);}//返回查詢結果returnbooks;}/***其它方法類似上面只是語句不同*/}當然以上只是簡單的封裝初學者可以在理解以上代碼的基礎上進行更高級的封裝5.使用BookDao添加書籍和獲取所有書籍列表importjava.util.List;/***測試類*@authorAdministrator**/publicclassTest{/***@paramargs*@throwsException*/publicstaticvoidmain(String[]args)throwsException{//創建工具類對象BookDao=newBookDao();//創建一本圖書Bookbook=newBook(null," :495691293","編程菜鳥");//添加書籍到資料庫.addBook(book);//獲取所有圖書列表Listbooks=.getBooks();//輸出結果for(Bookb:books){System.out.println(b.getId()+"\t"+b.getAuthor()+"\t"+b.getName());}}}

『陸』 關於jsp連SQL的疑問

public
ResultSet
select(String
sql)
//查詢數據函數
{
try
{
stmt=conn.createStatement(ResultSet.TYPE_SCROLL_
INSENSITIVE
,ResultSet.CONCUR_READ_ONLY);
rs=stmt.executeQuery(sql);
}
catch(
Exception
e)
{
e.printStackTrace();
}
你是直接調用
這個方法的，可是這個方法中的conn是null的啊！沒有值啊！
如果不想動的話，把public
void
getConnect()
這個方法里的內容寫到靜態代碼塊內。或無參構造內。

『柒』 visual studio怎麼做資料庫

publicclassStudentService
{

//從配置文件中讀取資料庫連接字元串
=ConfigurationManager.ConnectionStrings["accpConnectionString"].ToString();
=ConfigurationManager.ConnectionStrings["DataBaseOwner"].ToString();
AdoNetModels.Studentmodel=newStudent();
//conststringspName=".usp_DeleteStudent";

#region刪除數據1
publicintDeleteStudent(intstuID)
{
intresult=0;
//資料庫連接Connection對象
SqlConnectionconnection=newSqlConnection(connString);
//構建刪除的sql語句
stringsql=string.Format("DeleteFromStudentWherestuID={0}",stuID);
//定義command對象
SqlCommandcommand=newSqlCommand(sql,connection);

try
{
connection.Open();
result=command.ExecuteNonQuery();//執行命令
}
catch(Exceptionex)
{

Console.WriteLine(ex.Message);
}
finally
{
connection.Close();
}
returnresult;
}
#endregion

#region刪除數據2

publicintDeleteStudent2(intstuID)
{
intresult=0;
//構建刪除的sql語句使用參數
stringsql="DeleteFromStudentWherestuID=@stuID";

using(SqlConnectionconnection=newSqlConnection(connString))
{
SqlCommandobjCommand=newSqlCommand(sql,connection);

objCommand.Parameters.Add("@stuID",SqlDbType.Int).Value=stuID;

connection.Open();
result=objCommand.ExecuteNonQuery();
}
returnresult;

}
#endregion

publicintInsertStudent(Studentmodel)
{

intresult=0;
SqlConnectionconnection=newSqlConnection(connString);
//構建插入的sql語句
stringsql=string.Format("INSERTINTOStudent(stuName,age)values('{0}','{1}')",
model.StuName,model.Age);
//定義command對象
SqlCommandcommand=newSqlCommand(sql,connection);

try
{
connection.Open();
result=command.ExecuteNonQuery();//執行命令

}
catch(Exceptionex)
{

Console.WriteLine(ex.Message);
}
finally
{
connection.Close();
}

returnresult;
}

publicintInsertStudent2(Studentmodel)
{

intresult=0;
//構建插入的sql語句
stringsql="INSERTINTOStudent(age,stuName)values(@age,@stuName)";
using(SqlConnectionconnection=newSqlConnection(connString))
{
SqlCommandobjCommand=newSqlCommand(sql,connection);

objCommand.Parameters.Add("@age",SqlDbType.Int).Value=model.Age;
objCommand.Parameters.Add("@stuName",SqlDbType.NVarChar,50).Value=model.StuName;

connection.Open();
result=objCommand.ExecuteNonQuery();
}
returnresult;
}

publicintInsertStudent3(Studentmodel)
{
intresult=0;
using(SqlConnectionconnection=newSqlConnection(connString))
{
SqlCommandobjCommand=newSqlCommand(dboOwner+".usp_InsertStudent",connection);
objCommand.CommandType=CommandType.StoredProcere;

objCommand.Parameters.Add("@age",SqlDbType.Int).Value=model.Age;
objCommand.Parameters.Add("@stuName",SqlDbType.NVarChar,50).Value=model.StuName;

connection.Open();
result=objCommand.ExecuteNonQuery();
}
returnresult;

}

publicintInsertStudent5(Studentmodel)
{
intoutputResult=0;
intreturnvalue=0;
using(SqlConnectionconnection=newSqlConnection(connString))
{
SqlCommandobjCommand=newSqlCommand(dboOwner+".usp_InsertStudent",connection);
objCommand.CommandType=CommandType.StoredProcere;

objCommand.Parameters.Add("@age",SqlDbType.Int).Value=model.Age;
objCommand.Parameters.Add("@stuName",SqlDbType.NVarChar,50).Value=model.StuName;
//定義輸出參數
SqlParameterparameter=newSqlParameter("@stuID",SqlDbType.Int);
parameter.Direction=ParameterDirection.Output;
objCommand.Parameters.Add(parameter);

//定義ReturnValue參數
objCommand.Parameters.Add("ReturnValue",SqlDbType.Int);
objCommand.Parameters["ReturnValue"].Direction=ParameterDirection.ReturnValue;
connection.Open();
objCommand.ExecuteNonQuery();//執行命令
//獲取輸出參數的值在命令執行以後
outputResult=(int)objCommand.Parameters["@stuID"].Value;
//存儲過程中為定義return值默認為0
returnvalue=(int)objCommand.Parameters["ReturnValue"].Value;
}
returnreturnvalue;

}

publicIListGetAllStudents1()
{

IListdataList=newList();
DataSetdataSet=newDataSet(); //聲明並初始化DataSet
SqlDataAdapterdataAdapter; //聲明DataAdapter

using(SqlConnectionconn=newSqlConnection(connString))
{
//定義command對象
SqlCommandcommand=newSqlCommand(dboOwner+".usp_SelectStudentsAll",conn);
command.CommandType=CommandType.StoredProcere;
//Command定義帶參數的SQL語句的參數
//command.Parameters.Add("@stuID",SqlDbType.Int);
//給輸入參數賦值
//command.Parameters["@stuID"].Value=5;
conn.Open();
//初始化DataAdapter
dataAdapter=newSqlDataAdapter(command);

//填充DataSet
dataAdapter.Fill(dataSet,"dataSetName");

//處理數據集中的數據
foreach(DataRowrowindataSet.Tables[0].Rows)
{
Studentmodel=newStudent();
model.StuId=Convert.ToInt32(row["stuID"]);
model.StuName=Convert.ToString(row["stuName"]);
dataList.Add(model);

}

}
returndataList;

}

publicvoidMoreResult()
{
DataSetdataSet=newDataSet(); //聲明並初始化DataSet
SqlDataAdapterdataAdapter; //聲明DataAdapter

//定義查詢語句
stringsql=string.Format("SELECT*FROMstudentwherestuid>50;SELECT*FROMstudent");
SqlConnectionconnection=newSqlConnection(connString);
try
{
connection.Open();
//初始化DataAdapter
dataAdapter=newSqlDataAdapter(sql,connection);

//填充DataSet
dataAdapter.Fill(dataSet,"dataSetName");

//處理數據集中的數據
foreach(DataRowrowindataSet.Tables[0].Rows)
{
//intgradeId=(int)row["GradeID"];

}
}
catch(Exceptionex)
{

Console.WriteLine(ex.Message);
}
finally
{
connection.Close();
}

}

}
}

『捌』 java中PreparedStatement類的setString用法

setString是定義了字元串中第n個」?「字元的替換。
舉例：
string strsql = "select emp_id from employee where emp_id = ?";
preparedstatement pstmt = conn.preparestatement(strsql);
pstmt.setstring(1,"pma42628m");
解釋：此時sql中的"?"的值就是」pma42628m「。
代碼完整舉例：
import java.sql.*;
public class mypreparedstatement {
private final string db_driver="com.microsoft.jdbc.sqlserver.sqlserverdriver";
private final string url = "jdbc:microsoft:sqlserver://127.0.0.1:1433;databasename=pubs";
public mypreparedstatement()
{
}
public void query() throws sqlexception{
connection conn = this.getconnection();
string strsql = "select emp_id from employee where emp_id = ?";
preparedstatement pstmt = conn.preparestatement(strsql);
pstmt.setstring(1,"pma42628m");
resultset rs = pstmt.executequery();

while(rs.next()){
string fname = rs.getstring("emp_id");
system.out.println("the fname is " + fname);
}
rs.close();
pstmt.close();
conn.close();
}
private connection getconnection() throws sqlexception{
// class.
connection conn = null;
try {
class.forname(db_driver);
conn = drivermanager.getconnection(url,"sa","sa");
}
catch (classnotfoundexception ex) {}
return conn;
}
//main
public static void main(string[] args) throws sqlexception {
mypreparedstatement jdbctest1 = new mypreparedstatement();
jdbctest1.query();
}
}

『玖』 sqldatareader string 讀取變成 數組的一個問題

你可以定義一個string數組用for循環給他賦值，這樣你用的時候就方便點了
string sql = "select extra from EventExpand where Id="+eid;
private string[] row1;
row1=new string[];
for(int i=0;i<數組長度;i++)
{
try
{
using (SqlDataReader reader = DBHelper.GetReader(sql))
{
while (reader.Read())
{
row1[i]=reader["extra"].ToString().trim();
}
}
}
catch (Except
}

『拾』 如何在django shell中查看執行的資料庫sql語句

C#中執行SQL語句//SQL查詢語句publicDataTablequery(stringsql){//server=127.0.0.1;DataTabledt=newDataTable();//DataRowdr;stringconnString="server=127.0.0.1;uid=sa;pwd=;database=TJPTTC";SqlConnectionconn=newSqlConnection(connString);SqlDataAdapteradapter=newSqlDataAdapter(sql,conn);adapter.Fill(dt);returndt;}//SQL非查詢語句publicvoidnoQuery(stringsql){//server=127.0.0.1;stringconnString="server=GLASSESONION;uid=sa;pwd=;database=TJPTTC";SqlConnectionconn=newSqlConnection(connString);SqlCommandcmd=newSqlCommand(sql,conn);conn.Open();cmd.ExecuteNonQuery();conn.Close();}