2、点击“创建”,打开选择数据源页,选择“机器数据源”,点击“新建”;
3、点击下一步打开选择数据源驱动程序页,选择完成后点击下一步;
4、名称字段可以任意命名,服务器为数据库所在非服务器地址等信息后,点击下一步;
5、选择“使用用户输入登陆ID和密码的SQL Server验证”,录入要连接数据库的用户
C#读写txt文件的两种方法:1.添加命名空间
System.IO
System.Text
2.文件的读取
(1).使用FileStream类进行文件的读取,并将它转换成char数组,然后输出。
byte[] byData = new byte[100]
char[] charData = new char[1000]
public void Read()
{
try
{
FileStream file = new FileStream("E:\\test.txt", FileMode.Open)
file.Seek(0, SeekOrigin.Begin)
file.Read(byData, 0, 100)//byData传进来的字节数组,用以接受FileStream对象中的数据,第2个参数是字节数组中开始写入数据的位置,它通常是0,表示从数组的开端文件中向数组写数据,最后一个参数规定从文件读多少字符.
Decoder d = Encoding.Default.GetDecoder()
d.GetChars(byData, 0, byData.Length, charData, 0)
Console.WriteLine(charData)
file.Close()
}
catch (IOException e)
{
Console.WriteLine(e.ToString())
}
}
(2).使用StreamReader读取文件,然后一行一行的输出。
public void Read(string path)
{
StreamReader sr = new StreamReader(path,Encoding.Default)
String line
while ((line = sr.ReadLine()) != null)
{
Console.WriteLine(line.ToString())
}
}
3.文件的写入
(1).使用FileStream类创建文件,然后将数据写入到文件里。
public void Write()
{
FileStream fs = new FileStream("E:\\ak.txt", FileMode.Create)
//获得字节数组
byte[] data = System.Text.Encoding.Default.GetBytes("Hello World!")
//开始写入
fs.Write(data, 0, data.Length)
//清空缓冲区、关闭流
fs.Flush()
fs.Close()
}
(2).使用FileStream类创建文件,使用StreamWriter类,将数据写入到文件。
public void Write(string path)
{
FileStream fs = new FileStream(path, FileMode.Create)
StreamWriter sw = new StreamWriter(fs)
//开始写入
sw.Write("Hello World!!!!")
//清空缓冲区
sw.Flush()
//关闭流
sw.Close()
fs.Close()
}
读取数据库,首先要将数据库的驱动包导入:如果是mysql数据库,需要导入mysql-connector-java-5.1.27.jar,如果是oracle就需要导入oracle.jar包;然后就是建立数据库连接,使用Connection 新建连接,然后执行你的sql语句查询出需要的数据,下面是两个方法: public PageModel findAllUser(int pageNo,int pageSize){String sql = "select * from user where user_name <>'root' order by user_name" +"limit" + (pageNo - 1) * pageSize + "," + pageSizePageModel pageModel =nullConnection conn =nullStatement stmt =nullResultSet rs = nulltry{conn = DB.getConn()stmt = conn.createStatement()rs = stmt.executeQuery(sql)List user_List = new ArrayList()while(rs.next()){User user = new User()user.setUser_name(rs.getString("user_name"))user.setUser_password(rs.getString("user_password"))user.setUser_tel(rs.getString("user_tel"))user.setUser_email(rs.getString("user_email"))user.setUser_createDate(rs.getTimestamp("user_createdate"))user_List.add(user)}//取得所有记录int totalRecords = getTotalRecords(conn)pageModel = new PageModel()pageModel.setPageSize(pageSize)pageModel.setList(user_List)pageModel.setTotalRecord(totalRecords)}catch(SQLException e){e.printStackTrace()}finally{DB.close(rs)DB.close(stmt)DB.close(conn)}return pageModel} /** * 取得所有记录 * @param conn * @return 所有记录totalRecords */public int getTotalRecords(Connection conn){String sql = "select count(*) from user where user_name <>'root' "int totalRecords = 0Statement stmt = nullResultSet rs = nulltry{conn = DB.getConn()stmt = conn.createStatement()rs = stmt.executeQuery(sql)if(rs.next()){totalRecords = rs.getInt(1)}}catch(SQLException e){e.printStackTrace()}finally{DB.close(rs)DB.close(stmt)DB.close(conn)}return totalRecords}
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)