📄 checkdataservice.cs
字号:
using System;
using System.Collections;
using System.ComponentModel;
using System.Data;
using System.Diagnostics;
using System.ServiceProcess;
using System.IO;
using System.Data.SqlClient;
namespace Example2
{
public class CheckDataService : System.ServiceProcess.ServiceBase
{
/// <summary>
/// Required designer variable.
/// </summary>
private System.ComponentModel.Container components = null;
//User Defined variables
private SqlConnection objSqlConnection;
private SqlCommand objSqlCommand;
private SqlDataReader objSqlDataReader;
public CheckDataService()
{
// This call is required by the Windows.Forms Component Designer.
InitializeComponent();
// TODO: Add any initialization after the InitComponent call
}
// The main entry point for the process
static void Main()
{
System.ServiceProcess.ServiceBase[] ServicesToRun;
// More than one user Service may run within the same process. To add
// another service to this process, change the following line to
// create a second service object. For example,
//
// ServicesToRun = new System.ServiceProcess.ServiceBase[] {new Service1(), new MySecondUserService()};
//
ServicesToRun = new System.ServiceProcess.ServiceBase[] { new CheckDataService() };
System.ServiceProcess.ServiceBase.Run(ServicesToRun);
}
/// <summary>
/// Required method for Designer support - do not modify
/// the contents of this method with the code editor.
/// </summary>
private void InitializeComponent()
{
//
// CheckDataService
//
this.ServiceName = "CheckDataService";
}
/// <summary>
/// Clean up any resources being used.
/// </summary>
protected override void Dispose( bool disposing )
{
if( disposing )
{
if (components != null)
{
components.Dispose();
}
}
base.Dispose( disposing );
}
/// <summary>
/// Set things in motion so your service can do its work.
/// </summary>
protected override void OnStart(string[] args)
{
FileStream objFileStream = new FileStream("c:\\OrderDetails.txt",FileMode.OpenOrCreate,FileAccess.Write);;
StreamWriter objStreamWriter = new StreamWriter(objFileStream);
try
{
// TODO: Add code here to start your service.
objSqlConnection = new SqlConnection("Server = (local);database=Inventory;uid=sa;password=;");
objSqlCommand = new SqlCommand("select * from OrderDetails",objSqlConnection);
objSqlConnection.Open();
objSqlDataReader = objSqlCommand.ExecuteReader();
//reading the records
while(objSqlDataReader.Read())
{
int qty = Convert.ToInt32(objSqlDataReader["Quantity"]);
if(qty > 100)
{
//writing to files
objStreamWriter.WriteLine(objSqlDataReader["OrderDetailID"].ToString());
objStreamWriter.WriteLine(objSqlDataReader["ProductID"].ToString());
objStreamWriter.WriteLine(qty.ToString());
objStreamWriter.Flush();
}
}
}
catch(Exception ex)
{
System.Diagnostics.Debug.WriteLine(ex.Message);
}
}
/// <summary>
/// Stop this service.
/// </summary>
protected override void OnStop()
{
// TODO: Add code here to perform any tear-down necessary to stop your service.
//objForm = null;
}
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -